Package | Description |
---|---|
org.apache.flink.migration.runtime.checkpoint | |
org.apache.flink.migration.util |
Modifier and Type | Method and Description |
---|---|
SerializedValue<StateHandle<?>> |
KeyGroupState.getKeyGroupState()
Deprecated.
|
SerializedValue<StateHandle<?>> |
SubtaskState.getState()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,SerializedValue<StateHandle<?>>> |
TaskState.getUnwrappedKvStates(Set<Integer> keyGroupPartition)
Deprecated.
Retrieve the set of key-value state key groups specified by the given key group partition set.
|
Constructor and Description |
---|
KeyGroupState(SerializedValue<StateHandle<?>> keyGroupState,
long stateSize,
long duration)
Deprecated.
|
SubtaskState(SerializedValue<StateHandle<?>> state,
long stateSize,
long duration)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T> SerializedValue<T> |
SerializedValue.fromBytes(byte[] serializedData)
Deprecated.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.