Modifier and Type | Class and Description |
---|---|
class |
FsStateChangelogStorage
Filesystem-based implementation of
StateChangelogStorage . |
Modifier and Type | Method and Description |
---|---|
StateChangelogStorage<?> |
FsStateChangelogStorageFactory.createStorage(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
StateChangelogStorage<?> |
TaskStateManager.getStateChangelogStorage()
Returns the configured state changelog storage for this task.
|
StateChangelogStorage<?> |
TaskStateManagerImpl.getStateChangelogStorage() |
StateChangelogStorage<?> |
TaskExecutorStateChangelogStoragesManager.stateChangelogStorageForJob(JobID jobId,
Configuration configuration) |
Constructor and Description |
---|
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
StateChangelogStorage<?> stateChangelogStorage,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder) |
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
StateChangelogStorage<?> stateChangelogStorage,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder,
SequentialChannelStateReaderImpl sequentialChannelStateReader) |
Modifier and Type | Method and Description |
---|---|
StateChangelogStorage<?> |
StateChangelogStorageFactory.createStorage(Configuration configuration)
Create the storage based on a configuration.
|
static StateChangelogStorage<?> |
StateChangelogStorageLoader.load(Configuration configuration) |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryStateChangelogStorage
An in-memory (non-production) implementation of
StateChangelogStorage . |
Modifier and Type | Method and Description |
---|---|
StateChangelogStorage<?> |
InMemoryStateChangelogStorageFactory.createStorage(Configuration configuration) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.