Package org.apache.flink.examples.java.graph

Class ConnectedComponents.NeighborWithComponentIDJoin

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<Long,​Long>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>>
    Enclosing class:
    ConnectedComponents
    public static final class ConnectedComponents.NeighborWithComponentIDJoin
extends Object
implements org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<Long,​Long>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>>
    UDF that joins a (Vertex-ID, Component-ID) pair that represents the current component that a vertex is associated with, with a (Source-Vertex-ID, Target-VertexID) edge. The function produces a (Target-vertex-ID, Component-ID) pair.
    See Also:
    Serialized Form

    • Constructor Detail

      • NeighborWithComponentIDJoin

        public NeighborWithComponentIDJoin()

    • Method Detail

      • join

        public org.apache.flink.api.java.tuple.Tuple2<Long,​Long> join​(org.apache.flink.api.java.tuple.Tuple2<Long,​Long> vertexWithComponent,
                                                                    org.apache.flink.api.java.tuple.Tuple2<Long,​Long> edge)
        Specified by:
        join in interface org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<Long,​Long>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Long>>