protected abstract <K> CheckpointableKeyedStateBackend<K> |
AbstractChangelogStateBackend.restore(Environment env,
String operatorIdentifier,
KeyGroupRange keyGroupRange,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<ChangelogStateBackendHandle> stateBackendHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) |
protected <K> CheckpointableKeyedStateBackend<K> |
DeactivatedChangelogStateBackend.restore(Environment env,
String operatorIdentifier,
KeyGroupRange keyGroupRange,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<ChangelogStateBackendHandle> stateBackendHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) |
protected <K> CheckpointableKeyedStateBackend<K> |
ChangelogStateBackend.restore(Environment env,
String operatorIdentifier,
KeyGroupRange keyGroupRange,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<ChangelogStateBackendHandle> stateBackendHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) |