K
- The type of the key in the Keyed OperatorTransformation.T
- The type of the elements in the Keyed OperatorTransformation.@PublicEvolving public class KeyedOperatorTransformation<K,T> extends Object
KeyedOperatorTransformation
represents a OneInputOperatorTransformation
on
which operator state is partitioned by key using a provided KeySelector
.Modifier and Type | Method and Description |
---|---|
BootstrapTransformation<T> |
transform(KeyedStateBootstrapFunction<K,T> processFunction)
Applies the given
KeyedStateBootstrapFunction on the keyed input. |
BootstrapTransformation<T> |
transform(SavepointWriterOperatorFactory factory)
Method for passing user defined operators along with the type information that will transform
the OperatorTransformation.
|
public BootstrapTransformation<T> transform(KeyedStateBootstrapFunction<K,T> processFunction)
KeyedStateBootstrapFunction
on 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 Savepoint
.
processFunction
- The KeyedStateBootstrapFunction
that is called for each
element.OperatorTransformation
that can be added to a Savepoint
.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 streamBootstrapTransformation
that can be added to a Savepoint
.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.