Package org.apache.flink.state.forst.snapshot

Class ForStSnapshotStrategyBase.ForStSnapshotOperation

java.lang.Object

org.apache.flink.state.forst.snapshot.ForStSnapshotStrategyBase.ForStSnapshotOperation

All Implemented Interfaces:

org.apache.flink.runtime.state.SnapshotStrategy.SnapshotResultSupplier<org.apache.flink.runtime.state.KeyedStateHandle>

Enclosing class:

ForStSnapshotStrategyBase<K,R extends org.apache.flink.runtime.state.SnapshotResources>

protected abstract class ForStSnapshotStrategyBase.ForStSnapshotOperation
extends Object
implements org.apache.flink.runtime.state.SnapshotStrategy.SnapshotResultSupplier<org.apache.flink.runtime.state.KeyedStateHandle>

Common operation in native ForSt snapshot result supplier.

Field Summary

Fields

Modifier and Type	Field	Description
protected long	checkpointId
protected org.apache.flink.runtime.state.CheckpointStreamFactory	checkpointStreamFactory
protected org.apache.flink.core.fs.CloseableRegistry	tmpResourcesRegistry

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ForStSnapshotOperation(long checkpointId, org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory)

Method Summary

Modifier and Type	Method	Description
protected Optional<org.apache.flink.runtime.state.KeyedStateHandle>	getLocalSnapshot(org.apache.flink.runtime.state.SnapshotDirectory localBackupDirectory, org.apache.flink.runtime.state.StreamStateHandle localStreamStateHandle, List<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.state.SnapshotStrategy.SnapshotResultSupplier

get

Field Detail

checkpointId

protected final long checkpointId

checkpointStreamFactory

@Nonnull
protected final org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory

tmpResourcesRegistry

@Nonnull
protected final org.apache.flink.core.fs.CloseableRegistry tmpResourcesRegistry

Constructor Detail

ForStSnapshotOperation

protected ForStSnapshotOperation(long checkpointId,
                                 @Nonnull
                                 org.apache.flink.runtime.state.CheckpointStreamFactory checkpointStreamFactory)

Method Detail

getLocalSnapshot

protected Optional<org.apache.flink.runtime.state.KeyedStateHandle> getLocalSnapshot(org.apache.flink.runtime.state.SnapshotDirectory localBackupDirectory,
                                                                                     @Nullable
                                                                                     org.apache.flink.runtime.state.StreamStateHandle localStreamStateHandle,
                                                                                     List<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState)
                                                                              throws IOException

Throws:

IOException