|
Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Long,Long>> in method public join(current Tuple2<Long,Long>, candidate Tuple2<Long,Long>, out Collector<Tuple2<Long,Long>>) : void in class org.apache.flink.test.iterative.ConnectedComponentsWithSolutionSetFirstITCase.UpdateComponentIdMatchMirrored |
From |
To |
|
Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Long,Long>> in method public join(candidate Tuple2<Long,Long>, current Tuple2<Long,Long>, out Collector<Tuple2<Long,Long>>) : void in class org.apache.flink.test.iterative.ConnectedComponentsWithDeferredUpdateITCase.UpdateComponentIdMatchNonPreserving |
From |
To |
|
Move Method public join(currentVertexWithComponent Record, newVertexWithComponent Record, out Collector<Record>) : void from class org.apache.flink.test.iterative.ConnectedComponentsWithSolutionSetFirstITCase.UpdateComponentIdMatchMirrored to public join(candidate Tuple2<Long,Long>, current Tuple2<Long,Long>, out Collector<Tuple2<Long,Long>>) : void from class org.apache.flink.test.iterative.ConnectedComponentsWithDeferredUpdateITCase.UpdateComponentIdMatchNonPreserving |
From |
To |
|
Move Method public join(newVertexWithComponent Record, currentVertexWithComponent Record, out Collector<Record>) : void from class org.apache.flink.test.iterative.ConnectedComponentsWithDeferredUpdateITCase.UpdateComponentIdMatchNonPreserving to public join(current Tuple2<Long,Long>, candidate Tuple2<Long,Long>, out Collector<Tuple2<Long,Long>>) : void from class org.apache.flink.test.iterative.ConnectedComponentsWithSolutionSetFirstITCase.UpdateComponentIdMatchMirrored |
From |
To |