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) |
Modifier and Type | Method and Description |
---|---|
<ACC,V,R> WindowOperator<K,T,?,R,W> |
aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType) |
<ACC,V,R> WindowOperator<K,T,?,R,W> |
aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType) |
void |
allowedLateness(Time lateness) |
<R> WindowOperator<K,T,?,R,W> |
apply(WindowFunction<T,R,K,W> function) |
void |
evictor(Evictor<? super T,? super W> evictor) |
String |
generateOperatorName(Function function1,
Function function2) |
long |
getAllowedLateness() |
<R> WindowOperator<K,T,?,R,W> |
process(ProcessWindowFunction<T,R,K,W> function) |
<R> WindowOperator<K,T,?,R,W> |
reduce(ReduceFunction<T> reduceFunction,
ProcessWindowFunction<T,R,K,W> function) |
<R> WindowOperator<K,T,?,R,W> |
reduce(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function) |
void |
sideOutputLateData(OutputTag<T> outputTag) |
void |
trigger(Trigger<? super T,? super W> trigger) |
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)
public void allowedLateness(Time 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(Function function1, @Nullable Function function2)
@VisibleForTesting public long getAllowedLateness()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.