Package org.apache.flink.state.api
Class StateBootstrapTransformation<T>
- java.lang.Object
-
- org.apache.flink.state.api.StateBootstrapTransformation<T>
-
- Type Parameters:
T
- The input type of the transformation.
@PublicEvolving public class StateBootstrapTransformation<T> extends Object
AStateBootstrapTransformation
represents a procedure of writing new operator state into aSavepoint
. It is defined by aDataStream
containing the data to bootstrap with, a factory for a stream operator that consumes the elements of theDataStream
and generates state to be snapshotted, as well as an optional key selector if the new operator state is partitioned.