Serialized Form

Package org.apache.flink.contrib.streaming.state

Class org.apache.flink.contrib.streaming.state.RocksDBStateBackend extends org.apache.flink.runtime.state.AbstractStateBackend implements Serializable

serialVersionUID:

1L

Serialized Fields

checkpointStreamBackend

org.apache.flink.runtime.state.AbstractStateBackend checkpointStreamBackend

The state backend that we use for creating checkpoint streams.

operatorIdentifier

String operatorIdentifier

Operator identifier that is used to uniqueify the RocksDB storage path.

jobId

org.apache.flink.api.common.JobID jobId

JobID for uniquifying backup paths.

configuredDbBasePaths

org.apache.flink.core.fs.Path[] configuredDbBasePaths

Base paths for RocksDB directory, as configured. May be null.

initializedDbBasePaths

File[] initializedDbBasePaths

Base paths for RocksDB directory, as initialized

nextDirectory

int nextDirectory

predefinedOptions

PredefinedOptions predefinedOptions

The pre-configured option settings

optionsFactory

OptionsFactory optionsFactory

The options factory to create the RocksDB options in the cluster

enableIncrementalCheckpointing

boolean enableIncrementalCheckpointing

True if incremental checkpointing is enabled

Class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory extends Object implements Serializable

serialVersionUID:

4906988360901930371L

Package org.apache.flink.migration.contrib.streaming.state

Class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend extends org.apache.flink.migration.runtime.state.AbstractStateBackend implements Serializable

serialVersionUID:

1L

Class org.apache.flink.migration.contrib.streaming.state.RocksDBStateBackend.FinalFullyAsyncSnapshot extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

stateHandle

org.apache.flink.migration.runtime.state.StateHandle<T> stateHandle

checkpointId

long checkpointId