Graph

Submitting a Graph job is similar to submitting a job using MapReduce. The following section uses SSSP Algorithm as an example to show how to submit Graph jobs. Maven users can search “odps-sdk-graph” from Maven Library to get the required SDK (available in different versions). The related configuration information is as follows:

<dependency>
    <groupId>com.aliyun.odps</groupId>
    <artifactId>odps-sdk-graph</artifactId>
    <version>0.20.7</version>
</dependency>

To run a Graph job using the SSSP algorithm, follow these steps.

1. Enter the console and run “odpscmd”.

2. Create Input Table and Output Table.

   create table sssp_in (v bigint, es string);
   create table sssp_out (v bigint, l bigint);

   Note:
   

   For the statement to create table, see SQL Create.

3. Upload Data.
   The contents of local data is as follows:

   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

   “tab” button is taken as the separator of two columns.Upload the data:

   tunnel u -fd "," sssp.txt sssp_in;

4. Write SSSP example.
   According to the introduction in Graph Eclipse Plug-in, compile and debug SSSP Example on local.

   Note:
   You only need to package the SSSP code. You do not need to package the SDK in “odps-graph-example-sssp.jar”.

5. Add JAR package.

   add jar $LOCAL_JAR_PATH/odps-graph-example-sssp.jar odps-graph-example-sssp.jar

   NOTE:
   

   For resource creation, see Resource Operation.

6. Run SSSP.

   jar -libjars odps-graph-example-sssp.jar -classpath $LOCAL_JAR_PATH/odps-graph-example-sssp.jar
      com.aliyun.odps.graph.examples.SSSP 1 sssp_in sssp_out;

   JAR command is used to run MaxCompute GRAPH. Its use method is consistent with MapReduce.

   When GRAPH job is running, corresponding instance ID, execution schedule and result summary are printed on the command line, as follows:

   ID = 20130730160742915gl205u3
   2013-07-31 00:18:36     SUCCESS
   Summary:
   Graph Input/Output
   Total input bytes=211
   Total input records=5
   Total output bytes=161
   Total output records=5
   graph_input_[bsp.sssp_in]_bytes=211
   graph_input_[bsp.sssp_in]_records=5
   graph_output_[bsp.sssp_out]_bytes=161
   graph_output_[bsp.sssp_out]_records=5
   Graph Statistics
   Total edges=14
   Total halted vertices=5
   Total sent messages=28
   Total supersteps=4
   Total vertices=5
   Total workers=1
   Graph Timers
   Average superstep time (milliseconds)=7
   Load time (milliseconds)=8
   Max superstep time (milliseconds) =14
   Max time superstep=0
   Min superstep time (milliseconds)=5
   Min time superstep=2
   Setup time (milliseconds)=277
   Shutdown time (milliseconds)=20
   Total superstep time (milliseconds)=30
   Total time (milliseconds)=344
   OK

   NOTE:
   

   New users are recommended to submit their Graph job, and provide the name of the MaxCompute project and its usage scenario, to Alibaba Cloud. If the review of the job is successful, the Graph function is opened.