Uses of Interface
org.apache.flink.graph.EdgeJoinFunction

Packages that use EdgeJoinFunction

Package	Description
org.apache.flink.graph

Uses of EdgeJoinFunction in org.apache.flink.graph

Methods in org.apache.flink.graph with parameters of type EdgeJoinFunction

Modifier and Type	Method and Description
<T> Graph<K,VV,EV>	Graph.joinWithEdges(DataSet<Tuple3<K,K,T>> inputDataSet, EdgeJoinFunction<EV,T> edgeJoinFunction) Joins the edge DataSet with an input DataSet on the composite key of both source and target IDs and applies a user-defined transformation on the values of the matched records.
<T> Graph<K,VV,EV>	Graph.joinWithEdgesOnSource(DataSet<Tuple2<K,T>> inputDataSet, EdgeJoinFunction<EV,T> edgeJoinFunction) Joins the edge DataSet with an input Tuple2 DataSet and applies a user-defined transformation on the values of the matched records.
<T> Graph<K,VV,EV>	Graph.joinWithEdgesOnTarget(DataSet<Tuple2<K,T>> inputDataSet, EdgeJoinFunction<EV,T> edgeJoinFunction) Joins the edge DataSet with an input Tuple2 DataSet and applies a user-defined transformation on the values of the matched records.