Package | Description |
---|---|
org.apache.flink.migration.runtime.checkpoint.savepoint | |
org.apache.flink.migration.state | |
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.savepoint | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
static StreamStateHandle |
SavepointV0Serializer.convertOperatorAndFunctionState(StreamTaskState streamTaskState)
This is public so that we can use it when restoring a legacy snapshot
in
AbstractStreamOperatorTestHarness . |
static StreamStateHandle |
SavepointV0Serializer.convertStateHandle(StateHandle<?> oldStateHandle)
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.
|
class |
MigrationStreamStateHandle
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Constructor and Description |
---|
MigrationKeyGroupStateHandle(KeyGroupRangeOffsets groupRangeOffsets,
StreamStateHandle streamStateHandle)
Deprecated.
|
MigrationStreamStateHandle(StreamStateHandle delegate)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected StreamStateHandle |
AbstractAsyncSnapshotIOCallable.closeStreamAndGetStateHandle() |
StreamStateHandle |
CompletedCheckpoint.getExternalizedMetadata() |
StreamStateHandle |
OperatorSubtaskState.getLegacyOperatorState()
Deprecated.
Non-repartitionable operator state that has been deprecated.
Can be removed when we remove the APIs for non-repartitionable operator state.
|
Modifier and Type | Method and Description |
---|---|
ChainedStateHandle<StreamStateHandle> |
SubtaskState.getLegacyOperatorState()
Deprecated.
Non-repartitionable operator state that has been deprecated.
Can be removed when we remove the APIs for non-repartitionable operator state.
|
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
StreamStateHandle externalizedMetadata,
String externalPointer) |
OperatorSubtaskState(StreamStateHandle legacyOperatorState,
OperatorStateHandle managedOperatorState,
OperatorStateHandle rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState) |
Constructor and Description |
---|
SubtaskState(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
ChainedStateHandle<OperatorStateHandle> managedOperatorState,
ChainedStateHandle<OperatorStateHandle> rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState) |
Modifier and Type | Method and Description |
---|---|
static StreamStateHandle |
SavepointV1Serializer.deserializeStreamStateHandle(DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
static Tuple2<Savepoint,StreamStateHandle> |
SavepointStore.loadSavepointWithHandle(String savepointFileOrDirectory,
ClassLoader classLoader)
Loads the savepoint at the specified path.
|
Modifier and Type | Method and Description |
---|---|
static void |
SavepointV1Serializer.serializeStreamStateHandle(StreamStateHandle stateHandle,
DataOutputStream dos) |
Modifier and Type | Class and Description |
---|---|
class |
NonClosingCheckpointOutputStream<T extends StreamStateHandle>
Abstract class to implement custom checkpoint output streams which should not be closable for user code.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
class |
MultiStreamStateHandle
Wrapper class that takes multiple
StreamStateHandle and makes them look like a single one. |
class |
OperatorStateHandle
State handle for partitionable operator state.
|
class |
PlaceholderStreamStateHandle
A placeholder state handle for shared state that will replaced by an original that was
created in a previous checkpoint.
|
class |
RetrievableStreamStateHandle<T extends Serializable>
Wrapper around a
StreamStateHandle to make the referenced state object retrievable trough a simple get call. |
Modifier and Type | Method and Description |
---|---|
abstract StreamStateHandle |
CheckpointStreamFactory.CheckpointStateOutputStream.closeAndGetHandle()
Closes the stream and gets a state handle that can create an input stream
producing the data written to this stream.
|
StreamStateHandle |
OperatorStateHandle.getDelegateStateHandle() |
StreamStateHandle |
KeyGroupsStateHandle.getDelegateStateHandle() |
StreamStateHandle |
IncrementalKeyedStateHandle.getMetaStateHandle() |
StreamStateHandle |
SharedStateRegistry.Result.getReference() |
Modifier and Type | Method and Description |
---|---|
ChainedStateHandle<StreamStateHandle> |
TaskStateHandles.getLegacyOperatorState()
Deprecated.
Non-repartitionable operator state that has been deprecated.
Can be removed when we remove the APIs for non-repartitionable operator state.
|
Map<StateHandleID,StreamStateHandle> |
IncrementalKeyedStateHandle.getPrivateState() |
Map<StateHandleID,StreamStateHandle> |
IncrementalKeyedStateHandle.getSharedState() |
Modifier and Type | Method and Description |
---|---|
SharedStateRegistry.Result |
SharedStateRegistry.registerReference(SharedStateRegistryKey registrationKey,
StreamStateHandle state)
Register a reference to the given shared state in the registry.
|
Constructor and Description |
---|
IncrementalKeyedStateHandle(UUID backendIdentifier,
KeyGroupRange keyGroupRange,
long checkpointId,
Map<StateHandleID,StreamStateHandle> sharedState,
Map<StateHandleID,StreamStateHandle> privateState,
StreamStateHandle metaStateHandle) |
KeyGroupsStateHandle(KeyGroupRangeOffsets groupRangeOffsets,
StreamStateHandle streamStateHandle) |
OperatorStateHandle(Map<String,OperatorStateHandle.StateMetaInfo> stateNameToPartitionOffsets,
StreamStateHandle delegateStateHandle) |
Result(StreamStateHandle reference,
int referenceCount) |
RetrievableStreamStateHandle(StreamStateHandle streamStateHandle) |
Constructor and Description |
---|
IncrementalKeyedStateHandle(UUID backendIdentifier,
KeyGroupRange keyGroupRange,
long checkpointId,
Map<StateHandleID,StreamStateHandle> sharedState,
Map<StateHandleID,StreamStateHandle> privateState,
StreamStateHandle metaStateHandle) |
IncrementalKeyedStateHandle(UUID backendIdentifier,
KeyGroupRange keyGroupRange,
long checkpointId,
Map<StateHandleID,StreamStateHandle> sharedState,
Map<StateHandleID,StreamStateHandle> privateState,
StreamStateHandle metaStateHandle) |
MultiStreamStateHandle(List<StreamStateHandle> stateHandles) |
TaskStateHandles(ChainedStateHandle<StreamStateHandle> legacyOperatorState,
List<Collection<OperatorStateHandle>> managedOperatorState,
List<Collection<OperatorStateHandle>> rawOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState) |
Modifier and Type | Class and Description |
---|---|
class |
FileStateHandle
StreamStateHandle for state that was written to a file stream. |
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
FsCheckpointStreamFactory.FsCheckpointStateOutputStream.closeAndGetHandle() |
Modifier and Type | Class and Description |
---|---|
class |
ByteStreamStateHandle
A state handle that contains stream state in a byte array.
|
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
MemCheckpointStreamFactory.MemoryCheckpointOutputStream.closeAndGetHandle() |
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
StreamOperator.snapshotLegacyOperatorState(long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions)
Deprecated.
This method will be removed as soon as no more operators use the legacy state code paths
|
StreamStateHandle |
AbstractStreamOperator.snapshotLegacyOperatorState(long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions)
Deprecated.
Non-repartitionable operator state that has been deprecated.
Can be removed when we remove the APIs for non-repartitionable operator state.
|
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
OperatorStateHandles.getLegacyOperatorState() |
Constructor and Description |
---|
OperatorStateHandles(int operatorChainIndex,
StreamStateHandle legacyOperatorState,
Collection<KeyedStateHandle> managedKeyedState,
Collection<KeyedStateHandle> rawKeyedState,
Collection<OperatorStateHandle> managedOperatorState,
Collection<OperatorStateHandle> rawOperatorState) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.