Package com.alibaba.graphscope.graphx

Class GraphXParallelPIE<VD,ED,MSG_T>

java.lang.Object

com.alibaba.graphscope.graphx.GraphXParallelPIE<VD,ED,MSG_T>

public class GraphXParallelPIE<VD,ED,MSG_T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected IFragment<Long,Long,VD,ED>	iFragment
protected scala.Function2<MSG_T,MSG_T,MSG_T>	mergeMsg	(A, A) => A)
protected BaseArrowProjectedFragment<Long,Long,VD,ED>	projectedFragment

Constructor Summary

Constructors

Constructor	Description
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 Summary

Modifier and Type	Method	Description
int	curRound()
PrimitiveArray<VD>	getNewVdataArray()
BaseArrowProjectedFragment<Long,Long,VD,ED>	getProjectedFragment()
void	init(IFragment<Long,Long,VD,ED> fragment, ParallelMessageManager messageManager, int maxIterations, int parallelism, String workerIdToFid)
void	parallelExecute(InterruptibleTriConsumer<Integer,Integer,Integer> function, int limit)
boolean	parallelIncEval()
void	parallelPEval()
static <T> PrimitiveArray<T>	processComplexArray(StringTypedArray oldArray, Class<? extends T> clz, int length)
void	syncOuterVertexData()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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