@PublicEvolving @FunctionalInterface public interface SavepointWriterOperatorFactory
Modifier and Type | Method and Description |
---|---|
StreamOperator<TaggedOperatorSubtaskState> |
createOperator(long savepointTimestamp,
Path savepointPath)
Creates a
StreamOperator to be used for generating and snapshotting state. |
StreamOperator<TaggedOperatorSubtaskState> createOperator(long savepointTimestamp, Path savepointPath)
StreamOperator
to be used for generating and snapshotting state.savepointTimestamp
- the timestamp to associate with the generated savepoint.savepointPath
- the path to write the savepoint to.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.