Package org.apache.flink.runtime.state
Interface StateBackend.OperatorStateBackendParameters
-
- All Known Implementing Classes:
OperatorStateBackendParametersImpl
- Enclosing interface:
- StateBackend
@PublicEvolving public static interface StateBackend.OperatorStateBackendParameters
Parameters passed toStateBackend.createOperatorStateBackend(OperatorStateBackendParameters)
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CloseableRegistry
getCancelStreamRegistry()
StateBackend.CustomInitializationMetrics
getCustomInitializationMetrics()
Environment
getEnv()
String
getOperatorIdentifier()
Collection<OperatorStateHandle>
getStateHandles()
-
-
-
Method Detail
-
getEnv
Environment getEnv()
- Returns:
- The runtime environment of the executing task.
-
getOperatorIdentifier
String getOperatorIdentifier()
-
getStateHandles
@Nonnull Collection<OperatorStateHandle> getStateHandles()
-
getCancelStreamRegistry
CloseableRegistry getCancelStreamRegistry()
- Returns:
- The registry to which created closeable objects will be * registered during restore.
-
getCustomInitializationMetrics
StateBackend.CustomInitializationMetrics getCustomInitializationMetrics()
-
-