org.apache.flink.graph

Interface VertexJoinFunction<VV,T>

Type Parameters:

VV - the vertex value type

T - the input value type

All Superinterfaces:

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

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

Interface to be implemented by the transformation function applied in Graph.joinWithVertices(DataSet, VertexJoinFunction) method.

Method Summary

Modifier and Type	Method and Description
VV	vertexJoin(VV vertexValue, T inputValue) Applies a transformation on the current vertex value and the value of the matched tuple of the input DataSet.

Method Detail

vertexJoin

VV vertexJoin(VV vertexValue,
              T inputValue)
       throws Exception

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

Parameters:

vertexValue - the current vertex value

inputValue - the value of the matched Tuple2 input

Returns:

the new vertex value

Throws:

Exception