Uses of Class
org.apache.flink.streaming.api.windowing.time.Time
-
Packages that use Time Package Description org.apache.flink.streaming.api.datastream org.apache.flink.streaming.api.functions.timestamps org.apache.flink.streaming.api.windowing.assigners org.apache.flink.streaming.api.windowing.evictors org.apache.flink.streaming.api.windowing.time org.apache.flink.streaming.api.windowing.triggers org.apache.flink.streaming.runtime.operators.windowing This package contains the operators that implement the various window operations on data streams. -
-
Uses of Time in org.apache.flink.streaming.api.datastream
Constructors in org.apache.flink.streaming.api.datastream with parameters of type Time Constructor Description WithWindow(DataStream<T1> input1, DataStream<T2> input2, org.apache.flink.api.java.functions.KeySelector<T1,KEY> keySelector1, org.apache.flink.api.java.functions.KeySelector<T2,KEY> keySelector2, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, Time allowedLateness)WithWindow(DataStream<T1> input1, DataStream<T2> input2, org.apache.flink.api.java.functions.KeySelector<T1,KEY> keySelector1, org.apache.flink.api.java.functions.KeySelector<T2,KEY> keySelector2, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, Time allowedLateness) -
Uses of Time in org.apache.flink.streaming.api.functions.timestamps
Constructors in org.apache.flink.streaming.api.functions.timestamps with parameters of type Time Constructor Description BoundedOutOfOrdernessTimestampExtractor(Time maxOutOfOrderness)Deprecated. -
Uses of Time in org.apache.flink.streaming.api.windowing.assigners
Methods in org.apache.flink.streaming.api.windowing.assigners with parameters of type Time Modifier and Type Method Description static SlidingEventTimeWindowsSlidingEventTimeWindows. of(Time size, Time slide)Deprecated.static SlidingEventTimeWindowsSlidingEventTimeWindows. of(Time size, Time slide, Time offset)Deprecated.static SlidingProcessingTimeWindowsSlidingProcessingTimeWindows. of(Time size, Time slide)static SlidingProcessingTimeWindowsSlidingProcessingTimeWindows. of(Time size, Time slide, Time offset)Deprecated.static TumblingEventTimeWindowsTumblingEventTimeWindows. of(Time size)Deprecated.static TumblingEventTimeWindowsTumblingEventTimeWindows. of(Time size, Time offset)Deprecated.static TumblingEventTimeWindowsTumblingEventTimeWindows. of(Time size, Time offset, WindowStagger windowStagger)Deprecated.static TumblingProcessingTimeWindowsTumblingProcessingTimeWindows. of(Time size)Deprecated.static TumblingProcessingTimeWindowsTumblingProcessingTimeWindows. of(Time size, Time offset)Deprecated.static TumblingProcessingTimeWindowsTumblingProcessingTimeWindows. of(Time size, Time offset, WindowStagger windowStagger)static EventTimeSessionWindowsEventTimeSessionWindows. withGap(Time size)Deprecated.static ProcessingTimeSessionWindowsProcessingTimeSessionWindows. withGap(Time size)Deprecated. -
Uses of Time in org.apache.flink.streaming.api.windowing.evictors
Methods in org.apache.flink.streaming.api.windowing.evictors with parameters of type Time Modifier and Type Method Description static <W extends Window>
TimeEvictor<W>TimeEvictor. of(Time windowSize)Deprecated.static <W extends Window>
TimeEvictor<W>TimeEvictor. of(Time windowSize, boolean doEvictAfter)Deprecated. -
Uses of Time in org.apache.flink.streaming.api.windowing.time
Methods in org.apache.flink.streaming.api.windowing.time that return Time Modifier and Type Method Description static TimeTime. days(long days)Deprecated.Creates a newTimethat represents the given number of days.static TimeTime. hours(long hours)Deprecated.Creates a newTimethat represents the given number of hours.static TimeTime. milliseconds(long milliseconds)Deprecated.Creates a newTimethat represents the given number of milliseconds.static TimeTime. minutes(long minutes)Deprecated.Creates a newTimethat represents the given number of minutes.static TimeTime. of(long size, TimeUnit unit)Deprecated.static TimeTime. of(Duration duration)Deprecated.static TimeTime. seconds(long seconds)Deprecated.Creates a newTimethat represents the given number of seconds.Methods in org.apache.flink.streaming.api.windowing.time with parameters of type Time Modifier and Type Method Description static DurationTime. toDuration(Time time)Deprecated. -
Uses of Time in org.apache.flink.streaming.api.windowing.triggers
Methods in org.apache.flink.streaming.api.windowing.triggers with parameters of type Time Modifier and Type Method Description static <W extends Window>
ContinuousEventTimeTrigger<W>ContinuousEventTimeTrigger. of(Time interval)Deprecated.static <W extends Window>
ContinuousProcessingTimeTrigger<W>ContinuousProcessingTimeTrigger. of(Time interval)Deprecated. -
Uses of Time in org.apache.flink.streaming.runtime.operators.windowing
Methods in org.apache.flink.streaming.runtime.operators.windowing with parameters of type Time Modifier and Type Method Description voidWindowOperatorBuilder. allowedLateness(Time lateness)Deprecated.
-