Class RemoveTimestampMapFunction<T>

  • 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<T,​Long>,​T>

    @Internal
    public class RemoveTimestampMapFunction<T>
    extends Object
    implements org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<T,​Long>,​T>
    MapFunction which removes the timestamp field from the input element.
    See Also:
    Serialized Form
    • Constructor Detail

      • RemoveTimestampMapFunction

        public RemoveTimestampMapFunction()
    • Method Detail

      • map

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