Package | Description |
---|---|
org.apache.flink.state.changelog | |
org.apache.flink.state.changelog.restore |
Modifier and Type | Method and Description |
---|---|
<K> ChangelogKeyedStateBackend<K> |
ChangelogStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Method and Description |
---|---|
static <K,T extends ChangelogStateHandle> |
ChangelogBackendRestoreOperation.restore(StateChangelogHandleReader<T> changelogHandleReader,
ClassLoader classLoader,
Collection<ChangelogStateBackendHandle> stateHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder,
ChangelogBackendRestoreOperation.DeltaBackendBuilder<K> changelogBackendBuilder) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.