DataWorks：Logika Node For-Each

Tabel berikut menguraikan catatan penggunaan untuk node for-each:

Node for-each adalah jenis node khusus yang berisi node dalam. Saat Anda membuat node for-each, tiga node dalam berikut dibuat secara otomatis: start node (node awal loop), Shell node (node tugas loop), dan end node (node akhir loop). Node dalam diorganisasikan ke dalam alur kerja dalam untuk melakukan iterasi melalui output node penugasan.Gambar di atas menunjukkan informasi berikut:

• Shell node

  DataWorks secara otomatis membuat node tugas Shell dalam. Anda dapat menghapus node Shell default dan mengonfigurasi node tugas loop dalam sesuai kebutuhan bisnis Anda.

  • Jika Anda menggunakan node Shell sebagai node tugas loop dalam, klik dua kali Shell node dan edit kode node di tab konfigurasi node.

  • Jika tugas loop Anda rumit, Anda dapat menambahkan lebih banyak node dalam alur kerja dalam untuk memproses tugas loop dan menghubungkan node dalam sesuai kebutuhan bisnis Anda.

    null

    Saat menyesuaikan node tugas loop dalam dari node for-each, Anda dapat menghapus dependensi antara node dalam yang ada dari node for-each, dan mengonfigurasi alur kerja dalam sesuai kebutuhan bisnis Anda. Pastikan alur kerja dalam dimulai dengan start node dan diakhiri dengan end node.

• start dan end nodes

  Node start menandai dimulainya loop, sedangkan node end menandai berakhirnya loop. Kedua node tersebut tidak digunakan untuk memproses tugas loop.

  null

  Jumlah iterasi untuk node for-each ditentukan oleh output node penugasan, bukan oleh node akhir dari node for-each. Node penugasan dikonfigurasi sebagai node leluhur dari node for-each.

Jumlah iterasi untuk node for-each ditentukan oleh set hasil yang diteruskan oleh node penugasan:

• Jika node penugasan yang dikonfigurasikan sebagai node leluhur dari node for-each menggunakan Shell atau Python, jumlah iterasi untuk node for-each ditentukan oleh array satu dimensi yang dihasilkan. Jumlah iterasi sama dengan jumlah elemen dalam array satu dimensi. Elemen dipisahkan oleh koma (,).

  Sebagai contoh, jika node penugasan menggunakan Shell atau Python (Python 2), output dari node penugasan adalah array satu dimensi seperti 2021-03-28,2021-03-29,2021-03-30,2021-03-31,2021-04-01. Node for-each melakukan iterasi melalui output dari node penugasan sebanyak lima kali.

• Jika Anda menggunakan node SQL sebagai node tugas loop dalam dari node for-each, jumlah iterasi untuk node for-each ditentukan oleh array dua dimensi yang dihasilkan. Jumlah iterasi sama dengan jumlah baris dalam array dua dimensi.

  Sebagai contoh, jika ODPS SQL digunakan oleh node penugasan, output dari node penugasan adalah array dua dimensi:

  +----------------------------------------------+
  | uid            | region | age_range | zodiac |
  +----------------------------------------------+
  | 0016359810821  | Hubei Province | 30 to 40 years old   | Cancer |
  | 0016359814159  | Unknown   | 30 to 40 years old   | Cancer |
  +----------------------------------------------+

  Output tersebut menunjukkan bahwa node for-each melakukan iterasi melalui output dari node penugasan sebanyak dua kali.

Anda dapat menggunakan variabel bawaan yang disediakan oleh node for-each di DataWorks untuk mendapatkan jumlah iterasi yang telah selesai dan offset antara iterasi saat ini dan iterasi pertama saat node for-each digunakan untuk melakukan iterasi melalui output dari node penugasan.

data=[]

for(int i=0;i<data.length;i++) {
   print(data[i]);
}

Jika Anda sudah familiar dengan skema tabel output, Anda juga dapat menggunakan variabel dalam tabel berikut untuk mendapatkan nilai terkait di setiap iterasi.