MaxCompute:Kembangkan program graf

Tulis program graf

• Buat kelas MaxCompute Java.

  Topik ini menggunakan kelas BaseLoadingVertexResolver dan kelas SSSP sebagai contoh.

  1. Di panel Project, klik kanan direktori kode sumber modul (yaitu, src > main > java), lalu pilih New > MaxCompute Java.

  2. Masukkan Name, pilih GraphLoader atau Vertex sebagai tipe, lalu tekan Enter.

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

       Catatan

       Jika Anda belum membuat package, masukkan packagename.classname. Package akan dibuat secara otomatis.

     • Pilih GraphLoader atau Vertex. Daftar berikut menjelaskan tipe-tipe tersebut:

       • GraphLoader: Digunakan untuk memuat graf. Gunakan antarmuka setGraphLoaderClass dari GraphJob untuk menyediakan implementasi GraphLoader.

       • Vertex: Abstraksi dari vertex graf yang mencakup properti berikut: id, value, halted, dan edges. Gunakan antarmuka setVertexClass dari GraphJob untuk menyediakan implementasi Vertex.

  3. Setelah kelas dibuat, kembangkan program Java di editor. Untuk contoh kode kelas BaseLoadingVertexResolver dan kelas SSSP, lihat SSSP.

• Tambahkan dependensi yang diperlukan ke file pom.xml Anda.

  <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>
  <!-- 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, verifikasi di panel Maven bahwa dependensi telah dimuat.

Debug dengan menjalankan secara lokal

Jalankan program graf secara lokal untuk memverifikasi bahwa output sesuai dengan harapan Anda.

1. Klik kanan file Java dan pilih Run.

2. Di kotak dialog Run/Debug Configurations, konfigurasikan parameter eksekusi.

   Untuk MaxCompute project, pilih local dari daftar drop-down di sebelah kiri dan proyek target, misalnya example_project, dari daftar di sebelah kanan.

   • MaxCompute project: Proyek tempat Anda akan menjalankan program graf.

   • Download Record limit: Jumlah maksimum catatan yang diunduh. Nilai default adalah 100.

3. Klik OK untuk memulai eksekusi.

   Untuk eksekusi lokal, program membaca data dari tabel yang ditentukan di direktori warehouse sebagai input. Anda dapat melihat output log di konsol. Untuk informasi lebih lanjut tentang direktori warehouse, lihat direktori warehouse.

Paket dan unggah

Setelah men-debug program, kemas program tersebut ke dalam file JAR dan unggah ke MaxCompute sebagai resource. Untuk informasi lebih lanjut, lihat Paket, unggah, dan daftarkan.

Jalankan program graf

1. Di panel navigasi kiri IntelliJ IDEA, buka panel Project.

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

3. Di panel Console, jalankan program graf. Perintah berikut diberikan sebagai contoh. Sebelum menjalankan perintah, ganti kelas utama, tabel input, dan tabel output dengan nilai aktual Anda.

   Untuk perintah lainnya, lihat Perintah JAR.

   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 graf.

   • pagerank_in: Tabel input.

   • pagerank_out: Tabel output.