K- The type of the key in the Keyed OperatorTransformation.
T- The type of the elements in the Keyed OperatorTransformation.
@PublicEvolving @Deprecated public class KeyedOperatorTransformation<K,T> extends Object
OneInputOperatorTransformationon which operator state is partitioned by key using a provided
|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
KeyedStateBootstrapFunctionthat is called for each element.
OperatorTransformationthat can be added to a
public BootstrapTransformation<T> transform(SavepointWriterOperatorFactory factory)
IMPORTANT: Any output from this operator will be discarded.
factory- A factory returning transformation logic type of the return stream
BootstrapTransformationthat can be added to a
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–2023 The Apache Software Foundation. All rights reserved.