Class ConnectedComponents.DuplicateValue<T>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<T,​org.apache.flink.api.java.tuple.Tuple2<T,​T>>
    Enclosing class:
    ConnectedComponents

    public static final class ConnectedComponents.DuplicateValue<T>
    extends Object
    implements org.apache.flink.api.common.functions.MapFunction<T,​org.apache.flink.api.java.tuple.Tuple2<T,​T>>
    Function that turns a value into a 2-tuple where both fields are that value.
    See Also:
    Serialized Form
    • Constructor Detail

      • DuplicateValue

        public DuplicateValue()
    • Method Detail

      • map

        public org.apache.flink.api.java.tuple.Tuple2<T,​T> map​(T vertex)
        Specified by:
        map in interface org.apache.flink.api.common.functions.MapFunction<T,​org.apache.flink.api.java.tuple.Tuple2<T,​T>>