Class KeyRemovingMapper<T,​K>

  • Type Parameters:
    T - type of values
    K - type of keys
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<K,​T>,​T>, org.apache.flink.api.common.functions.RichFunction

    @Internal
    public final class KeyRemovingMapper<T,​K>
    extends org.apache.flink.api.common.functions.RichMapFunction<org.apache.flink.api.java.tuple.Tuple2<K,​T>,​T>
    Mapper that removes keys.
    See Also:
    Serialized Form
    • Constructor Detail

      • KeyRemovingMapper

        public KeyRemovingMapper()
    • Method Detail

      • map

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