Modifier and Type | Method and Description |
---|---|
Time |
Pattern.getWindowTime() |
Modifier and Type | Method and Description |
---|---|
Pattern<T,F> |
Pattern.within(Time windowTime)
Defines the maximum time interval in which a matching pattern has to be completed in
order to be considered valid.
|
Modifier and Type | Method and Description |
---|---|
AllWindowedStream<T,W> |
AllWindowedStream.allowedLateness(Time lateness)
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.
|
WindowedStream<T,KEY,TimeWindow> |
KeyedStream.timeWindow(Time size)
Windows this
KeyedStream into tumbling time windows. |
WindowedStream<T,KEY,TimeWindow> |
KeyedStream.timeWindow(Time size,
Time slide)
Windows this
KeyedStream into sliding time windows. |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size)
Windows this
DataStream into tumbling time windows. |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size,
Time slide)
Windows this
DataStream into sliding time windows. |
Constructor and Description |
---|
BoundedOutOfOrdernessTimestampExtractor(Time maxOutOfOrderness) |
Modifier and Type | Method and Description |
---|---|
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size)
Creates a new
TumblingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp. |
static TumblingTimeWindows |
TumblingTimeWindows.of(Time size)
Deprecated.
Please use
TumblingEventTimeWindows.of(Time) . |
static TumblingEventTimeWindows |
TumblingEventTimeWindows.of(Time size)
Creates a new
TumblingEventTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp. |
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 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 SlidingAlignedProcessingTimeWindows |
SlidingAlignedProcessingTimeWindows.of(Time size,
Time slide)
Creates a new
SlidingAlignedProcessingTimeWindows WindowAssigner that assigns
elements to sliding 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 SlidingTimeWindows |
SlidingTimeWindows.of(Time size,
Time slide)
Deprecated.
Please use
SlidingEventTimeWindows.of(Time, Time) . |
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 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,
Time offset)
Creates a new
SlidingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp and offset. |
static ProcessingTimeSessionWindows |
ProcessingTimeSessionWindows.withGap(Time size)
Creates a new
SessionWindows WindowAssigner that assigns
elements to sessions based on the element timestamp. |
static EventTimeSessionWindows |
EventTimeSessionWindows.withGap(Time size)
Creates a new
SessionWindows WindowAssigner that assigns
elements to sessions based on the element timestamp. |
Modifier and Type | Method and Description |
---|---|
static <W extends Window> |
TimeEvictor.of(Time windowSize)
Creates a
TimeEvictor that keeps the given number of elements. |
static <W extends Window> |
TimeEvictor.of(Time windowSize,
boolean doEvictAfter)
Creates a
TimeEvictor that keeps the given number of elements. |
Modifier and Type | Method and 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)
|
static Time |
Time.seconds(long seconds)
Creates a new
Time that represents the given number of seconds. |
Modifier and Type | Method and Description |
---|---|
static <W extends Window> |
ContinuousEventTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
static <W extends Window> |
ContinuousProcessingTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
Modifier and Type | Method and Description |
---|---|
PythonWindowedStream |
PythonKeyedStream.time_window(Time size)
A thin wrapper layer over
KeyedStream.timeWindow(Time) . |
PythonWindowedStream |
PythonKeyedStream.time_window(Time size,
Time slide)
A thin wrapper layer over
KeyedStream.timeWindow(Time, Time) . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.