static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(java.time.Duration size) |
Creates a new TumblingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp.
|
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(java.time.Duration size,
java.time.Duration offset) |
Creates a new TumblingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp and offset.
|
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(java.time.Duration size,
java.time.Duration 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 TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size) |
Deprecated.
|
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size,
Time offset) |
Deprecated.
|
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size,
Time offset,
WindowStagger windowStagger) |
Deprecated.
|