K
- The type of key returned by the KeySelector
.T
- The type of the incoming elements.W
- The type of Window
that the WindowAssigner
assigns.public class WindowOperatorBuilder<T,K,W extends Window> extends Object
WindowOperators
.Constructor and Description |
---|
WindowOperatorBuilder(WindowAssigner<? super T,W> windowAssigner,
Trigger<? super T,? super W> trigger,
ExecutionConfig config,
TypeInformation<T> inputType,
KeySelector<T,K> keySelector,
TypeInformation<K> keyType) |
public WindowOperatorBuilder(WindowAssigner<? super T,W> windowAssigner, Trigger<? super T,? super W> trigger, ExecutionConfig config, TypeInformation<T> inputType, KeySelector<T,K> keySelector, TypeInformation<K> keyType)
@Deprecated public void allowedLateness(Time lateness)
allowedLateness(Duration)
.public void allowedLateness(Duration lateness)
public <R> WindowOperator<K,T,?,R,W> reduce(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function)
public <R> WindowOperator<K,T,?,R,W> reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function)
public <ACC,V,R> WindowOperator<K,T,?,R,W> aggregate(AggregateFunction<T,ACC,V> aggregateFunction, WindowFunction<V,R,K,W> windowFunction, TypeInformation<ACC> accumulatorType)
public <ACC,V,R> WindowOperator<K,T,?,R,W> aggregate(AggregateFunction<T,ACC,V> aggregateFunction, ProcessWindowFunction<V,R,K,W> windowFunction, TypeInformation<ACC> accumulatorType)
public <R> WindowOperator<K,T,?,R,W> apply(WindowFunction<T,R,K,W> function)
public <R> WindowOperator<K,T,?,R,W> process(ProcessWindowFunction<T,R,K,W> function)
public String generateOperatorName()
public String generateOperatorDescription(Function function1, @Nullable Function function2)
@VisibleForTesting public long getAllowedLateness()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.