Field Detail

• mergeMsg

  protected scala.Function2<MSG_T,​MSG_T,​MSG_T> mergeMsg

  (A, A) => A)

• iFragment

  protected IFragment<Long,​Long,​VD,​ED> iFragment

• projectedFragment

  protected BaseArrowProjectedFragment<Long,​Long,​VD,​ED> projectedFragment

Constructor Detail

• GraphXParallelPIE

  public GraphXParallelPIE​(GraphXConf<VD,​ED,​MSG_T> conf,
                           scala.Function3<Long,​VD,​MSG_T,​VD> vprog,
                           scala.Function1<org.apache.spark.graphx.EdgeTriplet<VD,​ED>,​scala.collection.Iterator<scala.Tuple2<Long,​MSG_T>>> sendMsg,
                           scala.Function2<MSG_T,​MSG_T,​MSG_T> mergeMsg,
                           MSG_T initialMessage,
                           org.apache.spark.graphx.EdgeDirection direction)

Method Detail

• getNewVdataArray

  public PrimitiveArray<VD> getNewVdataArray()

• getProjectedFragment

  public BaseArrowProjectedFragment<Long,​Long,​VD,​ED> getProjectedFragment()

• init

  public void init​(IFragment<Long,​Long,​VD,​ED> fragment,
                   ParallelMessageManager messageManager,
                   int maxIterations,
                   int parallelism,
                   String workerIdToFid)
            throws IOException,
                   ClassNotFoundException

  Throws:

  IOException

  ClassNotFoundException

• curRound

  public int curRound()

• parallelExecute

  public void parallelExecute​(InterruptibleTriConsumer<Integer,​Integer,​Integer> function,
                              int limit)

• syncOuterVertexData

  public void syncOuterVertexData()

• parallelPEval

  public void parallelPEval()

• parallelIncEval

  public boolean parallelIncEval()

• processComplexArray

  public static <T> PrimitiveArray<T> processComplexArray​(StringTypedArray oldArray,
                                                          Class<? extends T> clz,
                                                          int length)
                                                   throws IOException,
                                                          ClassNotFoundException

  Throws:

  IOException

  ClassNotFoundException