Package org.apache.flink.streaming.api.functions.python.eventtime
-
Class Summary Class Description CustomTimestampAssigner<T> TimestampAssigner which extracts timestamp from the second field of the input element.RemoveTimestampMapFunction<T> MapFunction which removes the timestamp field from the input element.