Package com.alibaba.graphscope.communication

Class Communicator

java.lang.Object

com.alibaba.graphscope.communication.Communicator

Direct Known Subclasses:

GiraphComputationAdaptor, PageRank

public class Communicator
extends Object

Communicator providing useful distributed aggregation methods such as min/min/sum.

Constructor Summary

Constructors

Constructor	Description
Communicator()

Method Summary

Modifier and Type	Method	Description
FFICommunicator	getFFICommunicator()
<MSG_T> void	max(MSG_T msgIn, MSG_T msgOut)	Obtain the max of msgIn among all distributed app instances, and put the result in msgOut.
<MSG_T> void	min(MSG_T msgIn, MSG_T msgOut)	Obtain the min of msgIn among all distributed app instances, and put the result in msgOut.
<MSG_T> void	sum(MSG_T msgIn, MSG_T msgOut)	Obtain the sum of msgIn among all distributed app instances, and put the result in msgOut.

Methods inherited from class java.lang.Object

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

Constructor Detail

Communicator

public Communicator()

Method Detail

getFFICommunicator

public FFICommunicator getFFICommunicator()

sum

public <MSG_T> void sum(MSG_T msgIn,
                        MSG_T msgOut)

Obtain the sum of msgIn among all distributed app instances, and put the result in msgOut. MSG_T should be a sub class of FFIMirror.

Type Parameters:

MSG_T - msg type, should be a FFIMirror, DoubleMsg or LongMsg

Parameters:

msgIn - data to be aggregated.

msgOut - placeholder to receive the result.

See Also:

FFIMirror, DoubleMsg, LongMsg

min

public <MSG_T> void min(MSG_T msgIn,
                        MSG_T msgOut)

Obtain the min of msgIn among all distributed app instances, and put the result in msgOut. MSG_T should be a sub class of FFIMirror.

Type Parameters:

MSG_T - msg type, should be a FFIMirror, DoubleMsg or LongMsg.

Parameters:

msgIn - data to be aggregated.

msgOut - placeholder to received the result.

See Also:

FFIMirror, DoubleMsg, LongMsg

max

public <MSG_T> void max(MSG_T msgIn,
                        MSG_T msgOut)

Obtain the max of msgIn among all distributed app instances, and put the result in msgOut. MSG_T should be a sub class of FFIMirror.

Type Parameters:

MSG_T - msg type, should be a FFIMirror, DoubleMsg or LongMsg.

Parameters:

msgIn - data to be aggregated.

msgOut - placeholder to received the result.