public < T > Graph < K , VV , EV > joinWithEdgesOnSource ( DataSet < Tuple2 < K , T > > inputDataSet , final EdgeJoinFunction < EV , T > edgeJoinFunction ) { DataSet < Edge < K , EV > > resultedEdges = this . getEdges ( ) . coGroup ( inputDataSet ) . where ( 0 ) . equalTo ( 0 ) . with ( new ApplyCoGroupToEdgeValuesOnEitherSourceOrTarget <> ( edgeJoinFunction ) ) . name ( "Join with edges on source" ) ; return new Graph <> ( this . vertices , resultedEdges , this . context ) ; }
Joins the edge DataSet with an input Tuple2 DataSet and applies a user - defined transformation on the values of the matched records . The source ID of the edges input and the first field of the input DataSet are used as join keys .