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

Methods in org.apache.flink.streaming.api.datastream with parameters of type Time

Modifier and Type	Method	Description
AllWindowedStream<T,W>	AllWindowedStream.allowedLateness(Time lateness)	Sets the time by which elements are allowed to be late.
CoGroupedStreams.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.WithWindow.allowedLateness(Time newLateness)	Sets the time by which elements are allowed to be late.
JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.WithWindow.allowedLateness(Time newLateness)	Sets the time by which elements are allowed to be late.
WindowedStream<T,K,W>	WindowedStream.allowedLateness(Time lateness)	Sets the time by which elements are allowed to be late.
KeyedStream.IntervalJoined<T1,T2,KEY>	KeyedStream.IntervalJoin.between(Time lowerBound, Time upperBound)	Specifies the time boundaries over which the join operation works, so that
WindowedStream<T,KEY,TimeWindow>	KeyedStream.timeWindow(Time size)	Deprecated. Please use KeyedStream.window(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows.
WindowedStream<T,KEY,TimeWindow>	KeyedStream.timeWindow(Time size, Time slide)	Deprecated. Please use KeyedStream.window(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows.
AllWindowedStream<T,TimeWindow>	DataStream.timeWindowAll(Time size)	Deprecated. Please use DataStream.windowAll(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows.
AllWindowedStream<T,TimeWindow>	DataStream.timeWindowAll(Time size, Time slide)	Deprecated. Please use DataStream.windowAll(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows.

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)

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 SlidingEventTimeWindows	SlidingEventTimeWindows.of(Time size, Time slide)	Creates a new SlidingEventTimeWindows WindowAssigner that assigns elements to sliding time windows based on the element timestamp.
static SlidingEventTimeWindows	SlidingEventTimeWindows.of(Time size, Time slide, Time offset)	Creates a new SlidingEventTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp and offset.
static SlidingProcessingTimeWindows	SlidingProcessingTimeWindows.of(Time size, Time slide)	Creates a new SlidingProcessingTimeWindows WindowAssigner that assigns elements to sliding time windows based on the element timestamp.
static SlidingProcessingTimeWindows	SlidingProcessingTimeWindows.of(Time size, Time slide, Time offset)	Creates a new SlidingProcessingTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp and offset.
static TumblingEventTimeWindows	TumblingEventTimeWindows.of(Time size)	Creates a new TumblingEventTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp.
static TumblingEventTimeWindows	TumblingEventTimeWindows.of(Time size, Time offset)	Creates a new TumblingEventTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp and offset.
static TumblingEventTimeWindows	TumblingEventTimeWindows.of(Time size, Time offset, WindowStagger windowStagger)	Creates a new TumblingEventTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp, offset and a staggering offset, depending on the staggering policy.
static TumblingProcessingTimeWindows	TumblingProcessingTimeWindows.of(Time size)	Creates a new TumblingProcessingTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp.
static TumblingProcessingTimeWindows	TumblingProcessingTimeWindows.of(Time size, Time offset)	Creates a new TumblingProcessingTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp and offset.
static TumblingProcessingTimeWindows	TumblingProcessingTimeWindows.of(Time size, Time offset, WindowStagger windowStagger)	Creates a new TumblingProcessingTimeWindows WindowAssigner that assigns elements to time windows based on the element timestamp, offset and a staggering offset, depending on the staggering policy.
static EventTimeSessionWindows	EventTimeSessionWindows.withGap(Time size)	Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.
static ProcessingTimeSessionWindows	ProcessingTimeSessionWindows.withGap(Time size)	Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.

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)	Creates a TimeEvictor that keeps the given number of elements.
static <W extends Window> TimeEvictor<W>	TimeEvictor.of(Time windowSize, boolean doEvictAfter)	Creates a TimeEvictor that keeps the given number of elements.

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 Time	Time.days(long days)	Creates a new Time that represents the given number of days.
static Time	Time.hours(long hours)	Creates a new Time that represents the given number of hours.
static Time	Time.milliseconds(long milliseconds)	Creates a new Time that represents the given number of milliseconds.
static Time	Time.minutes(long minutes)	Creates a new Time that represents the given number of minutes.
static Time	Time.of(long size, TimeUnit unit)	Creates a new Time of the given duration and TimeUnit.
static Time	Time.seconds(long seconds)	Creates a new Time that represents the given number of seconds.

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)	Creates a trigger that continuously fires based on the given interval.
static <W extends Window> ContinuousProcessingTimeTrigger<W>	ContinuousProcessingTimeTrigger.of(Time interval)	Creates a trigger that continuously fires based on the given interval.

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
void	WindowOperatorBuilder.allowedLateness(Time lateness)