public class WindowOperatorBuilder extends Object
WindowOperatorBuilder
is used to build WindowOperator
fluently.
WindowOperatorBuilder .builder(KeyedStream) .tumble(Duration.ofMinutes(1)) // sliding(...), session(...) .withEventTime() // withProcessingTime() .aggregate(AggregationsFunction, accTypes, windowTypes) .withAllowedLateness(Duration.ZERO) .withSendRetraction() .build();
Constructor and Description |
---|
WindowOperatorBuilder() |
public static WindowOperatorBuilder builder()
public WindowOperatorBuilder withInputFields(LogicalType[] inputFieldTypes)
public WindowOperatorBuilder tumble(java.time.Duration size)
public WindowOperatorBuilder sliding(java.time.Duration size, java.time.Duration slide)
public WindowOperatorBuilder session(java.time.Duration sessionGap)
public WindowOperatorBuilder countWindow(long size)
public WindowOperatorBuilder countWindow(long size, long slide)
public WindowOperatorBuilder assigner(WindowAssigner<?> windowAssigner)
public WindowOperatorBuilder triggering(Trigger<?> trigger)
public WindowOperatorBuilder withEventTime(int rowtimeIndex)
public WindowOperatorBuilder withProcessingTime()
public WindowOperatorBuilder withAllowedLateness(java.time.Duration allowedLateness)
public WindowOperatorBuilder aggregate(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
public WindowOperatorBuilder aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)
public WindowOperatorBuilder withSendRetraction()
public WindowOperator build()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.