Package | Description |
---|---|
org.apache.flink.table.runtime.operators.window |
Modifier and Type | Method and Description |
---|---|
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() |
Constructor and Description |
---|
AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction,
GeneratedRecordEqualiser generatedEqualiser,
WindowOperatorBuilder windowOperatorBuilder) |
AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
WindowOperatorBuilder windowOperatorBuilder) |
TableAggregateWindowOperatorBuilder(GeneratedNamespaceTableAggsHandleFunction<?> generatedTableAggregateFunction,
WindowOperatorBuilder windowOperatorBuilder) |
TableAggregateWindowOperatorBuilder(NamespaceTableAggsHandleFunction<?> tableAggregateFunction,
WindowOperatorBuilder windowOperatorBuilder) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.