Uses of Interface
org.apache.flink.runtime.state.changelog.StateChangelogStorage

Packages that use StateChangelogStorage

Package	Description
org.apache.flink.changelog.fs
org.apache.flink.runtime.state
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.state.changelog.inmemory

Uses of StateChangelogStorage in org.apache.flink.changelog.fs

Classes in org.apache.flink.changelog.fs that implement StateChangelogStorage

Modifier and Type	Class and Description
class	FsStateChangelogStorage Filesystem-based implementation of StateChangelogStorage.

Methods in org.apache.flink.changelog.fs that return StateChangelogStorage

Modifier and Type	Method and Description
StateChangelogStorage<?>	FsStateChangelogStorageFactory.createStorage(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)

Uses of StateChangelogStorage in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return StateChangelogStorage

Modifier and Type	Method and Description
StateChangelogStorage<?>	TaskStateManagerImpl.getStateChangelogStorage()
StateChangelogStorage<?>	TaskStateManager.getStateChangelogStorage() Returns the configured state changelog storage for this task.
StateChangelogStorage<?>	TaskExecutorStateChangelogStoragesManager.stateChangelogStorageForJob(JobID jobId, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)

Methods in org.apache.flink.runtime.state that return types with arguments of type StateChangelogStorage

Modifier and Type	Method and Description
Optional<StateChangelogStorage<?>>	TaskExecutorStateChangelogStoragesManager.getChangelogStoragesByJobId(JobID jobId)

Constructors in org.apache.flink.runtime.state with parameters of type StateChangelogStorage

Constructor and Description
TaskStateManagerImpl(JobID jobId, ExecutionAttemptID executionAttemptID, TaskLocalStateStore localStateStore, StateChangelogStorage<?> stateChangelogStorage, TaskExecutorStateChangelogStoragesManager changelogStoragesManager, JobManagerTaskRestore jobManagerTaskRestore, CheckpointResponder checkpointResponder)
TaskStateManagerImpl(JobID jobId, ExecutionAttemptID executionAttemptID, TaskLocalStateStore localStateStore, StateChangelogStorage<?> stateChangelogStorage, TaskExecutorStateChangelogStoragesManager changelogStoragesManager, JobManagerTaskRestore jobManagerTaskRestore, CheckpointResponder checkpointResponder, SequentialChannelStateReaderImpl sequentialChannelStateReader)

Uses of StateChangelogStorage in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog that return StateChangelogStorage

Modifier and Type	Method and Description
StateChangelogStorage<?>	StateChangelogStorageFactory.createStorage(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig) Create the storage based on a configuration.
static StateChangelogStorage<?>	StateChangelogStorageLoader.load(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)

Uses of StateChangelogStorage in org.apache.flink.runtime.state.changelog.inmemory

Classes in org.apache.flink.runtime.state.changelog.inmemory that implement StateChangelogStorage

Modifier and Type	Class and Description
class	InMemoryStateChangelogStorage An in-memory (non-production) implementation of StateChangelogStorage.

Methods in org.apache.flink.runtime.state.changelog.inmemory that return StateChangelogStorage

Modifier and Type	Method and Description
StateChangelogStorage<?>	InMemoryStateChangelogStorageFactory.createStorage(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)