Komponen algoritma Merge Columns menggabungkan dua tabel dengan menambahkan kolom-kolomnya secara berdampingan. Kedua tabel input harus memiliki jumlah baris yang sama; jika tidak, akan terjadi error. Jika salah satu tabel merupakan tabel partisi, hubungkan tabel partisi tersebut ke port input kedua.
Konfigurasi komponen
Anda dapat mengonfigurasi komponen Merge Columns dengan cara berikut.
Metode 1: Konfigurasi visual
Pada tab Field Settings, gunakan Customize Output Columns from Left Table dan Customize Output Columns from Right Table untuk memilih kolom yang akan ditampilkan pada tabel output.
Metode 2: Perintah PAI
Konfigurasikan komponen menggunakan perintah PAI dalam komponen SQL Script. Untuk informasi selengkapnya, lihat SQL Script.
PAI -name appendColumns
-project algo_public
-DinputTableNames=maple_test_appendcol_basic_input1,maple_test_appendcol_basic_input2
-DoutputTableName=maple_test_appendcol_setOutCol_output
-DoutputTableColNames=x0,x1,x2,x3,x4,x5,x6,x7,x8,x9;
| Parameter | Wajib | Deskripsi | Bawaan |
| inputTableNames | Ya | Nama dua tabel input, dipisahkan dengan koma (,). | Tidak ada |
| outputTableName | Ya | Nama tabel output. | Tidak ada |
| selectedColNamesList | Tidak | Daftar nama kolom yang dipilih sesuai dengan tabel input.
Catatan Jika Anda memilih semua kolom dari kedua tabel, Anda harus membungkus seluruh nilai parameter dengan tanda kutip ganda (""). Jika tidak, sistem akan menganggap titik koma ( ;) sebagai penghenti perintah. Jika Anda memilih semua kolom dari satu tabel, Anda dapat menghilangkan nama kolom untuk tabel tersebut tetapi tetap harus menyertakan titik koma (;). |
Tidak ada |
| inputPartitionsInfoList | Tidak | Daftar partisi yang dipilih sesuai dengan tabel input.
Catatan Jika Anda memilih semua partisi, Anda harus membungkus seluruh nilai parameter dengan tanda kutip ganda (""). Jika tidak, sistem akan menganggap titik koma ( ;) sebagai penghenti perintah. Jika suatu tabel tidak dipartisi, Anda dapat menghilangkan nama partisi tetapi tetap harus menyertakan titik koma (;). |
Tidak ada |
| autoRenameCol | Tidak | Menentukan apakah nama kolom pada tabel output akan diubah secara otomatis. | false |
| outputTableColNames | Tidak | Nama baru untuk kolom-kolom pada tabel output. Jika Anda mengosongkan parameter ini, nama kolom asli akan digunakan. Penting Parameter ini tidak berpengaruh jika autoRenameCol diatur ke true. |
Tidak ada |
| lifecycle | Tidak | Siklus hidup tabel output, dalam satuan hari. Nilainya harus berupa bilangan bulat positif. | Tidak ada |
| coreNum | Tidak | Jumlah core untuk pekerjaan. Parameter ini digunakan bersama dengan memSizePerCore. Nilainya harus berupa bilangan bulat positif dalam rentang [1, 9999]. |
Ditentukan oleh sistem |
| memSizePerCore | Tidak | Ukuran memori per core, dalam MB. Nilainya harus berupa bilangan bulat positif dalam rentang [1024, 65536]. | Ditentukan oleh sistem |
Contoh
Contoh ini menggabungkan dua tabel sumber berikut:
- Tabel sumber 1
Tabel 1. maple_test_appendcol_basic_input1 col0:bigint col1:double col2:string col3:Datetime col4:Boolean 10 0.0 aaaa 2015-10-01 00:00:00 TRUE 11 1.0 aaaa 2015-10-01 00:00:00 FALSE 12 2.0 aaaa 2015-10-01 00:00:00 TRUE 13 3.0 aaaa 2015-10-01 00:00:00 TRUE 14 4.0 aaaa 2015-10-01 00:00:00 TRUE - Tabel sumber 2
Tabel 2. maple_test_appendcol_basic_input2 col10:bigint col11:double col12:string col13:Datetime col14:Boolean 110 10.0 2aaaa 2015-10-01 00:00:00 TRUE 111 11.0 2aaaa 2015-10-01 00:00:00 FALSE 112 12.0 2aaaa 2015-10-01 00:00:00 TRUE 113 13.0 2aaaa 2015-10-01 00:00:00 TRUE 114 14.0 2aaaa 2015-10-01 00:00:00 FALSE
PAI -name appendColumns
-project algo_public
-DinputTableNames=maple_test_appendcol_basic_input1,maple_test_appendcol_basic_input2
-DoutputTableName=maple_test_appendcol_setOutCol_output
-DoutputTableColNames=x0,x1,x2,x3,x4,x5,x6,x7,x8,x9;Perintah tersebut menghasilkan tabel output berikut.| x0 | x1 | x2 | x3 | x4 | x5 | x6 | x7 | x8 | x9 |
| 10 | 0 | aaaa | 2015-10-01 00:00:00 | true | 110 | 10 | 2aaaa | 2015-10-01 00:00:00 | true |
| 11 | 1 | aaaa | 2015-10-01 00:00:00 | false | 111 | 11 | 2aaaa | 2015-10-01 00:00:00 | false |
| 12 | 2 | aaaa | 2015-10-01 00:00:00 | true | 112 | 12 | 2aaaa | 2015-10-01 00:00:00 | true |
| 13 | 3 | aaaa | 2015-10-01 00:00:00 | true | 113 | 13 | 2aaaa | 2015-10-01 00:00:00 | true |
| 14 | 4 | aaaa | 2015-10-01 00:00:00 | true | 114 | 14 | 2aaaa | 2015-10-01 00:00:00 | false |