MaxCompute:Desarrollo de un programa de grafos

Requisitos previos

Complete las siguientes tareas:

1. Manage project connections

2. Create a MaxCompute Java module

Escritura de un programa de grafos

• Cree una clase Java de MaxCompute.

  Este tema utiliza como ejemplos la clase BaseLoadingVertexResolver y la clase SSSP .

  1. En el panel Project, haga clic con el botón derecho en el directorio de código fuente del módulo (es decir, src > main > java) y seleccione New > MaxCompute Java.

  2. Introduzca un Name, seleccione GraphLoader o Vertex como tipo y presione Enter.

     • Name: Introduzca el nombre de la clase Java de MaxCompute que desea crear.

       Nota

       Si no ha creado un paquete, introduzca packagename.classname. El paquete se crea automáticamente.

     • Seleccione GraphLoader o Vertex. La siguiente lista describe los tipos:

       • GraphLoader: Se utiliza para cargar un grafo. Use la interfaz setGraphLoaderClass de GraphJob para proporcionar una implementación de GraphLoader.

       • Vertex: Es una abstracción de un vértice de grafo. Incluye las siguientes propiedades: id, value, halted y edges. Use la interfaz setVertexClass de GraphJob para proporcionar una implementación de Vertex.

  3. Una vez creada la clase, desarrolle el programa Java en el editor. Para consultar el código de ejemplo de la clase BaseLoadingVertexResolver y la clase SSSP, consulte SSSP.

• Agregue las dependencias obligatorias a su archivo pom.xml.

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

  Después de configurar el archivo pom.xml, compruebe en el panel Maven que las dependencias se hayan cargado correctamente.

Depuración mediante ejecución local

Ejecute el programa de grafos localmente para verificar que la salida cumpla con sus expectativas.

1. Haga clic con el botón derecho en el archivo Java y seleccione Run.

2. En el cuadro de diálogo Run/Debug Configurations, configure los parámetros de ejecución.

   Para MaxCompute project, seleccione local en la lista desplegable de la izquierda y el proyecto de destino, por ejemplo example_project, en la de la derecha.

   • MaxCompute project: El proyecto donde se ejecutará el programa de grafos.

   • Download Record limit: El número máximo de registros para descargar. El valor predeterminado es 100.

3. Haga clic en OK para iniciar la ejecución.

   En una ejecución local, el programa lee datos de la tabla especificada en el directorio warehouse como entrada. Puede consultar la salida del registro en la consola. Para obtener más información sobre el directorio warehouse, consulte warehouse directory.

Empaquetado y carga

Una vez depurado el programa, empáquelo en un archivo JAR y cárguelo en MaxCompute como recurso. Para obtener más información, consulte Package, upload, and register.

Ejecución del programa de grafos

1. En el panel de navegación izquierdo de IntelliJ IDEA, abra el panel Project.

2. Haga clic con el botón derecho en el nombre del proyecto y seleccione Open in Console.

3. En el panel Console, ejecute el programa de grafos. El siguiente comando se proporciona como ejemplo. Antes de ejecutarlo, reemplace la clase principal, la tabla de entrada y la tabla de salida con sus valores reales.

   Para consultar más comandos, vea JAR commands.

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

   • PageRank: La clase principal definida en el programa de grafos.

   • pagerank_in: La tabla de entrada.

   • pagerank_out: La tabla de salida.