Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.output.operators |
Modifier and Type | Method and Description |
---|---|
StateBootstrapTransformation<T> |
KeyedStateTransformation.transform(KeyedStateBootstrapFunction<K,T> processFunction)
Applies the given
KeyedStateBootstrapFunction on the keyed input. |
BootstrapTransformation<T> |
KeyedOperatorTransformation.transform(KeyedStateBootstrapFunction<K,T> processFunction)
Deprecated.
Applies the given
KeyedStateBootstrapFunction on the keyed input. |
Constructor and Description |
---|
KeyedStateBootstrapOperator(long timestamp,
Path savepointPath,
KeyedStateBootstrapFunction<K,IN> function) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.