Field Detail

• pathPrefix

  public static final String pathPrefix

  See Also:

  Constant Field Values

Constructor Detail

• GraphXParallelAdaptorContext

  public GraphXParallelAdaptorContext​(Class<? extends VDATA_T> vdClass,
                                      Class<? extends EDATA_T> edClass,
                                      Class<? extends MSG> msgClass,
                                      scala.Function3<Long,​VDATA_T,​MSG,​VDATA_T> vprog,
                                      scala.Function1<org.apache.spark.graphx.EdgeTriplet<VDATA_T,​EDATA_T>,​scala.collection.Iterator<scala.Tuple2<Long,​MSG>>> sendMsg,
                                      scala.Function2<MSG,​MSG,​MSG> mergeMsg,
                                      MSG initialMsg,
                                      String appName,
                                      String vineyardSocket,
                                      org.apache.spark.graphx.EdgeDirection edgeDirection)

Method Detail

• createImpl

  public static <VD,​ED,​M> GraphXParallelAdaptorContext<VD,​ED,​M> createImpl​(Class<? extends VD> vdClass,
                                                                                                   Class<? extends ED> edClass,
                                                                                                   Class<? extends M> msgClass,
                                                                                                   scala.Function3 vprog,
                                                                                                   scala.Function1 sendMsg,
                                                                                                   scala.Function2 mergeMsg,
                                                                                                   Object initMsg,
                                                                                                   String appName,
                                                                                                   String vineyardSocket,
                                                                                                   org.apache.spark.graphx.EdgeDirection direction)

• create

  public static <VD,​ED,​M> GraphXParallelAdaptorContext<VD,​ED,​M> create​(URLClassLoader classLoader,
                                                                                               String serialPath)
                                                                                        throws ClassNotFoundException

  Throws:

  ClassNotFoundException

• getAppName

  public String getAppName()

• getConf

  public GraphXConf getConf()

• getGraphXProxy

  public GraphXParallelPIE<VDATA_T,​EDATA_T,​MSG> getGraphXProxy()

• Init

  public void Init​(IFragment<Long,​Long,​VDATA_T,​EDATA_T> frag,
                   ParallelMessageManager messageManager,
                   com.alibaba.fastjson.JSONObject jsonObject)

  Called by grape framework, before any PEval. You can initiating data structures need during super steps here.

  Specified by:

  Init in interface ParallelContextBase<Long,​Long,​VDATA_T,​EDATA_T>

  Parameters:

  frag - The graph fragment providing accesses to graph data.

  messageManager - The message manger which manages messages between fragments.

  jsonObject - String args from cmdline.

  See Also:

  IFragment, ParallelMessageManager, JSONObject

• Output

  public void Output​(IFragment<Long,​Long,​VDATA_T,​EDATA_T> frag)

  Output will be executed when the computations finalizes. Data maintained in this context shall be outputted here.

  Specified by:

  Output in interface ParallelContextBase<Long,​Long,​VDATA_T,​EDATA_T>

  Parameters:

  frag - The graph fragment contains the graph info.

  See Also:

  IFragment