WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
WindowOperatorBuilder |
WindowOperatorBuilder.assigner(WindowAssigner<?> windowAssigner) |
static WindowOperatorBuilder |
WindowOperatorBuilder.builder() |
WindowOperatorBuilder |
WindowOperatorBuilder.countWindow(long size) |
WindowOperatorBuilder |
WindowOperatorBuilder.countWindow(long size,
long slide) |
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.withSendRetraction() |