org.apache.flink.streaming.runtime.operators.windowing

Class WindowOperatorBuilder<T,K,W extends Window>

java.lang.Object

org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder<T,K,W>

Type Parameters:

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

A builder for creating WindowOperators.

Constructor Summary

Constructors

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)

Method Summary

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	generateOperatorDescription(Function function1, Function function2)
String	generateOperatorName()
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WindowOperatorBuilder

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)

Method Detail

trigger

public void trigger(Trigger<? super T,? super W> trigger)

allowedLateness

public void allowedLateness(Time lateness)

sideOutputLateData

public void sideOutputLateData(OutputTag<T> outputTag)

evictor

public void evictor(Evictor<? super T,? super W> evictor)

reduce

public <R> WindowOperator<K,T,?,R,W> reduce(ReduceFunction<T> reduceFunction,
                                            WindowFunction<T,R,K,W> function)

reduce

public <R> WindowOperator<K,T,?,R,W> reduce(ReduceFunction<T> reduceFunction,
                                            ProcessWindowFunction<T,R,K,W> function)

aggregate

public <ACC,V,R> WindowOperator<K,T,?,R,W> aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
                                                     WindowFunction<V,R,K,W> windowFunction,
                                                     TypeInformation<ACC> accumulatorType)

aggregate

public <ACC,V,R> WindowOperator<K,T,?,R,W> aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
                                                     ProcessWindowFunction<V,R,K,W> windowFunction,
                                                     TypeInformation<ACC> accumulatorType)

apply

public <R> WindowOperator<K,T,?,R,W> apply(WindowFunction<T,R,K,W> function)

process

public <R> WindowOperator<K,T,?,R,W> process(ProcessWindowFunction<T,R,K,W> function)

generateOperatorName

public String generateOperatorName()

generateOperatorDescription

public String generateOperatorDescription(Function function1,
                                          @Nullable
                                          Function function2)

getAllowedLateness

@VisibleForTesting
public long getAllowedLateness()