MaxCompute：Mengembangkan Program Graph

Tulis program Graph

• Buat Kelas Java MaxCompute.

  Topik ini menggunakan pembuatan kelas BaseLoadingVertexResolver dan kelas SSSP sebagai contoh.

  1. Di panel navigasi sisi kiri tab Project, pilih src > main > java, klik kanan java, lalu pilih New > MaxCompute Java.

     

  2. Tentukan Name, pilih GraphLoader atau Vertex, lalu tekan Enter.

     

     • Name: nama kelas Java MaxCompute yang ingin Anda buat.

       Catatan

       Jika tidak ada paket yang dibuat, masukkan packagename.classname. Sistem akan secara otomatis membuat paket.

     • Pilih GraphLoader atau Vertex sebagai tipe kelas.

       Catatan

       • GraphLoader: memuat graf. Anda dapat menentukan kelas ini dengan menggunakan metode setGraphLoaderClass dari GraphJob.

       • Vertex: mendefinisikan vertex dalam graf. Vertex memiliki properti berikut: id, value, halted, dan edges. Anda dapat menentukan kelas ini dengan menggunakan metode setVertexClass dari GraphJob.

  3. Setelah membuat kelas Java MaxCompute, kembangkan program Java di editor. Untuk detail lebih lanjut tentang kelas BaseLoadingVertexResolver dan kelas SSSP, lihat SSSP.

• Konfigurasikan file pom.xml. Kode berikut menunjukkan dependensi yang harus Anda impor:

  <dependency>
      <groupId>com.aliyun.odps</groupId>
      <artifactId>odps-sdk-core</artifactId>
      <version>0.48.0-public</version>
  </dependency>
  <dependency>
      <groupId>com.aliyun.odps</groupId>
      <artifactId>odps-sdk-graph</artifactId>
      <version>0.48.0-public</version>
  </dependency>
  
  <!-- digunakan untuk pengujian lokal -->
  <dependency>
      <groupId>com.aliyun.odps</groupId>
      <artifactId>odps-graph-local</artifactId>
      <version>0.48.0-public</version>
  </dependency>

  Setelah mengonfigurasi file pom.xml, Anda dapat memverifikasi bahwa dependensi berhasil dimuat di panel Maven.

Debug program Graph

Jalankan program Graph secara lokal dan periksa apakah hasilnya sesuai dengan harapan Anda.

1. Klik kanan skrip Java yang Anda tulis dan pilih Run.

2. Dalam kotak dialog Run/Debug Configurations, konfigurasikan parameter waktu proses.

   

   • MaxCompute project: proyek MaxCompute tempat Anda ingin menjalankan program Graph.

   • Download Record limit: jumlah maksimum catatan yang dapat diunduh. Nilai default: 100.

3. Klik OK untuk menjalankan UDF.

   Topik ini memilih eksekusi lokal, sehingga sistem membaca data dari tabel yang ditentukan di direktori warehouse sebagai input. Anda dapat melihat output log di konsol. Untuk informasi lebih lanjut tentang warehouse, lihat Ikhtisar.

Kemas dan unggah program MapReduce

Setelah men-debug program MapReduce yang Anda tulis, kemas program tersebut menjadi file JAR dan unggah file tersebut ke proyek MaxCompute Anda sebagai sumber daya. Untuk informasi lebih lanjut, lihat Kemas, unggah, dan daftarkan program Java.

Jalankan program Graph

1. Di panel navigasi sisi kiri alat IntelliJ IDEA, klik Project Explorer.

2. Klik kanan nama proyek MaxCompute Anda dan pilih Open in Console.

3. Di bagian Console, jalankan perintah berikut. Ganti PageRank, pagerank_in, dan pagerank_out berdasarkan situasi aktual.

   Untuk perintah lainnya, lihat Kirim pekerjaan MapReduce.

   jar -libjars xxx.jar -classpath /Users/home/xxx.jar com.aliyun.odps.graph.examples.PageRank pagerank_in pagerank_out;

   • PageRank: kelas utama yang didefinisikan dalam program Graph.

   • pagerank_in: tabel input.

   • pagerank_out: tabel output.