org.apache.flink.runtime.state

Interface StateBackend.OperatorStateBackendParameters

All Known Implementing Classes:

OperatorStateBackendParametersImpl

Enclosing interface:

StateBackend

@PublicEvolving
public static interface StateBackend.OperatorStateBackendParameters

Parameters passed to StateBackend.createOperatorStateBackend(OperatorStateBackendParameters).

Method Summary

Modifier and Type	Method and 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()