MaxCompute:Graph işi yazma

Ön koşullar

• MaxCompute istemcisini yükleyip yapılandırdınız ve bir MaxCompute örnek bağlantısı kurdunuz. Daha fazla bilgi için bkz. MaxCompute istemcisi.

• IntelliJ IDEA 2024'ü ve bununla uyumlu, 2024 yılında güncellenmiş bir MaxCompute Studio sürümünü yükleyip yapılandırdınız. Daha fazla bilgi için bkz. MaxCompute Studio'yu yükleme ve MaxCompute Studio'yu yapılandırma.

• Apache Maven sürüm apache-maven-3.5.0 yapılandırdınız.

• JDK 1.8 veya sonraki bir sürümü yüklediniz.

• Bir veri dosyası hazırladınız. Bu konu, örnek olarak sssp.txt dosyasını kullanır.

  1 2:2,3:1,4:4
  2 1:2,3:2,4:1
  3 1:1,2:2,5:1
  4 1:4,2:1,5:1
  5 3:1,4:1

Yordam

1. MaxCompute istemcisini başlatın ve giriş tablosu sssp_in ile çıkış tablosu sssp_out'u oluşturmak için aşağıdaki komutları çalıştırın.

   CREATE TABLE sssp_in (v bigint, es string);
   CREATE TABLE sssp_out (vertex bigint, value bigint);

2. Verileri sssp.txt dosyasından sstp_in tablosuna yüklemek için Tunnel komutunu çalıştırın; sütun ayırıcı olarak boşluk karakterini kullanın.

   tunnel u -fd " " sssp.txt sssp_in;

   Not

   Bu örnekte, sssp.txt dosyası MaxCompute istemcisinin bin dizininde kaydedilmiştir. sssp.txt dosyanız için doğru yolu belirttiğinizden emin olun.

3. SSSP örneğini yazın.

   1. IntelliJ IDEA'da bir MaxCompute Java Module oluşturun ve adını odps-graph-example-sssp olarak belirleyin.

      Not

      Daha fazla bilgi için bkz. MaxCompute Java Module oluşturma.

   2. Yeni odps-graph-example-sssp modülünde BaseLoadingVertexResolver sınıfını ve SSSP sınıfını oluşturun. Tam Java kodu için bkz. Single Source Shortest Path içindeki yönlü grafik örneği. Aşağıdaki bağımlılıkları pom.xml dosyasına ekleyin.

      <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>
      
      <!-- For local testing -->
      <dependency>
          <groupId>com.aliyun.odps</groupId>
          <artifactId>odps-graph-local</artifactId>
          <version>0.48.0-public</version>
      </dependency>

   3. IntelliJ IDEA'da MaxCompute Studio kullanarak projeyi paketleyin. Ayrıntılı talimatlar için bkz. Paketleme, yükleme ve kaydetme.

      Not

      Bu örnekte, MaxCompute projesine dağıtılan JAR paketi odps-graph-example-sssp.jar olarak adlandırılmıştır.

4. MaxCompute istemcisinde SSSP işini çalıştırmak için aşağıdaki komutu çalıştırın.

   jar -libjars odps-graph-example-sssp.jar -classpath <LOCAL_JAR_PATH>/odps-graph-example-sssp.jar SSSP 1 sssp_in sssp_out;

   LOCAL_JAR_PATH: odps-graph-example-sssp.jar dosyasının yerel yolu.

   İş tamamlandığında, sssp_out tablosunu sorgulamak ve sonucu doğrulamak için select * from sssp_out; komutunu çalıştırın.

   vertex    value
   1        0
   2        2
   3        1
   4        3
   5        2

   • vertex: Bir köğün ID'si.

   • value: İlgili kökten kaynak köğe (1) olan en kısa mesafe.

   Not

   Graph özellikini kullanmak için yalnızca bir Graph işi göndermeniz yeterlidir.