org.apache.flink.graph

Interface EdgeJoinFunction<EV,T>

Type Parameters:

EV - the edge value type

T - the input value type

All Superinterfaces:

org.apache.flink.api.common.functions.Function, Serializable

public interface EdgeJoinFunction<EV,T>
extends org.apache.flink.api.common.functions.Function, Serializable

Interface to be implemented by the transformation function applied in Graph.joinWithEdges(DataSet, EdgeJoinFunction), Graph.joinWithEdgesOnSource(DataSet, EdgeJoinFunction), and Graph.joinWithEdgesOnTarget(DataSet, EdgeJoinFunction) methods.

Method Summary

Modifier and Type	Method and Description
EV	edgeJoin(EV edgeValue, T inputValue) Applies a transformation on the current edge value and the value of the matched tuple of the input DataSet.

Method Detail

edgeJoin

EV edgeJoin(EV edgeValue,
            T inputValue)
     throws Exception

Applies a transformation on the current edge value and the value of the matched tuple of the input DataSet.

Parameters:

edgeValue - the current edge value

inputValue - the value of the matched Tuple2 input

Returns:

the new edge value

Throws:

Exception