Pola transformasi data

Mengimpor Data di Java

Anthony Markham

VP Quant Developer

Fungsi Map

Mengubah setiap elemen dalam kolom

DoubleColumn celsius = DoubleColumn.create("Celsius", 0, 10, 20, 30);

DoubleColumn fahrenheit = celsius.map(c -> c * 9.0/5.0 + 32);
table.addColumns(fahrenheit.setName("Fahrenheit"));

Celsius	Fahrenheit
0.0	32.0
10.0	50.0
20.0	68.0
30.0	86.0

Fungsi Reduce

Menggabungkan semua nilai dalam kolom menjadi satu hasil
Menerapkan pola akumulator (seperti jumlah, maksimum, atau logika khusus)
Berguna untuk operasi statistik dan analitis

// Temukan total penjualan
double totalSales = table.doubleColumn("Sales").reduce(0, Double::sum);

// Temukan maksimum
double largeSales = table.doubleColumn("Sales").reduce(0, (acc, x) -> acc + (x > 5000 ? 1 : 0));

Iterasi Baris dengan forEach

Mengiterasi setiap baris dalam tabel

DoubleColumn difference = DoubleColumn.create("Difference");
table.forEach(row -> {
    double celsius = row.getDouble("Celsius");
    double fahrenheit = row.getDouble("Fahrenheit");
    difference.append(fahrenheit - celsius);
});

table.addColumns(difference);

Celsius	Fahrenheit	Difference
0.0	32.0	32.0
10.0	50.0	40.0
20.0	68.0	48.0

Pipa Transformasi

Menggabungkan beberapa operasi
Meningkatkan keterbacaan dan pemeliharaan kode kita ✅
Pemrosesan data yang efisien ✅

Table result = originalTable
    .where(numberColumn("Age").isGreaterThan(18)) // Filter pada Usia > 18

    .addColumns(
        numberColumn("Income").map(i -> i * 1.1).setName("AdjustedIncome")
    );


// Hitung rata-rata pendapatan
double avgIncome = result.doubleColumn("AdjustedIncome")
        .reduce(0.0, Double::sum) / result.rowCount();

Rekap

map() - menerapkan fungsi untuk mengubah nilai kolom
forEach() - iterasi melalui baris untuk mengakses beberapa kolom
reduce() - mengagregasi dan meringkas data menjadi nilai tunggal

Gambar yang menunjukkan tiga fungsi transformasi data

Ayo berlatih!

Mengimpor Data di Java