Package | Description |
---|---|
org.apache.flink.migration.runtime.checkpoint.savepoint | |
org.apache.flink.migration.state | |
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
static KeyGroupsStateHandle |
SavepointV0Serializer.convertKeyedBackendState(HashMap<String,KvStateSnapshot<?,?,?,?>> oldKeyedState,
int parallelInstanceIdx,
long checkpointID)
This is public so that we can use it when restoring a legacy snapshot
in
AbstractStreamOperatorTestHarness . |
Modifier and Type | Class and Description |
---|---|
class |
MigrationKeyGroupStateHandle
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Method and Description |
---|---|
KeyGroupsStateHandle |
KeyGroupsStateHandle.getIntersection(KeyGroupRange keyGroupRange) |
Modifier and Type | Method and Description |
---|---|
Collection<KeyGroupsStateHandle> |
StateInitializationContextImpl.getKeyGroupsStateHandles() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.