WindowOperatorBuilder |
WindowOperatorBuilder.assigner(WindowAssigner<?> windowAssigner) |
static WindowOperatorBuilder |
WindowOperatorBuilder.builder() |
WindowOperatorBuilder |
WindowOperatorBuilder.countWindow(long size) |
WindowOperatorBuilder |
WindowOperatorBuilder.countWindow(long size,
long slide) |
WindowOperatorBuilder |
WindowOperatorBuilder.cumulative(java.time.Duration size,
java.time.Duration step) |
WindowOperatorBuilder |
WindowOperatorBuilder.produceUpdates() |
WindowOperatorBuilder |
WindowOperatorBuilder.session(java.time.Duration sessionGap) |
WindowOperatorBuilder |
WindowOperatorBuilder.sliding(java.time.Duration size,
java.time.Duration slide) |
WindowOperatorBuilder |
WindowOperatorBuilder.triggering(Trigger<?> trigger) |
WindowOperatorBuilder |
WindowOperatorBuilder.tumble(java.time.Duration size) |
WindowOperatorBuilder |
WindowOperatorBuilder.withAllowedLateness(java.time.Duration allowedLateness) |
WindowOperatorBuilder |
WindowOperatorBuilder.withEventTime(int rowtimeIndex) |
WindowOperatorBuilder |
WindowOperatorBuilder.withInputFields(LogicalType[] inputFieldTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.withProcessingTime() |
WindowOperatorBuilder |
WindowOperatorBuilder.withShiftTimezone(java.time.ZoneId shiftTimeZone)
The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift
timezone is the timezone user configured in TableConfig, other cases the timezone is UTC
which means never shift when assigning windows.
|