|Modifier and Type||Method and Description|
Applies the given
Method for passing user defined operators along with the type information that will transform the OperatorTransformation.
Windows this transformation into a
public BootstrapTransformation<T> transform(KeyedStateBootstrapFunction<K,T> processFunction)
KeyedStateBootstrapFunctionon the keyed input.
The function will be called for every element in the input and can be used for writing
both keyed and operator state into a
public BootstrapTransformation<T> transform(SavepointWriterOperatorFactory factory)
IMPORTANT: Any output from this operator will be discarded.
public <W extends Window> WindowedOperatorTransformation<T,K,W> window(WindowAssigner<? super T,W> assigner)
WindowedOperatorTransformation, which bootstraps state that can be restored by a
WindowOperator. Elements are put into windows by a
WindowAssigner. The grouping of elements is done both by key and by window.
Trigger can be defined to
specify when windows are evaluated. However,
WindowAssigners have a default
Trigger that is used if a
Trigger is not specified.
WindowAssignerthat assigns elements to windows.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.