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

Class ForStSnapshotStrategyBase.ForStNativeSnapshotResources

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.runtime.state.SnapshotResources

Enclosing class:

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

protected static class ForStSnapshotStrategyBase.ForStNativeSnapshotResources
extends Object
implements org.apache.flink.runtime.state.SnapshotResources

A SnapshotResources for native ForSt snapshot.

Field Summary

Fields

Modifier and Type	Field	Description
protected List<org.apache.flink.core.fs.Path>	liveFiles
protected String	manifestFileName
protected org.apache.flink.core.fs.Path	manifestFilePath
protected long	manifestFileSize
protected ForStSnapshotStrategyBase.PreviousSnapshot	previousSnapshot
protected Runnable	releaser
protected List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot>	stateMetaInfoSnapshots

Constructor Summary

Constructors

Constructor	Description
ForStNativeSnapshotResources(List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot> stateMetaInfoSnapshots, long manifestFileSize, List<org.apache.flink.core.fs.Path> liveFiles, org.apache.flink.core.fs.Path manifestFilePath, ForStSnapshotStrategyBase.PreviousSnapshot previousSnapshot, Runnable releaser)

Method Summary

Modifier and Type	Method	Description
String	getCurrentFileContent()
void	release()
void	setPreviousSnapshot(ForStSnapshotStrategyBase.PreviousSnapshot previousSnapshot)

Methods inherited from class java.lang.Object

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

Field Detail

stateMetaInfoSnapshots

@Nonnull
protected final List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot> stateMetaInfoSnapshots

manifestFileSize

protected final long manifestFileSize

liveFiles

@Nonnull
protected final List<org.apache.flink.core.fs.Path> liveFiles

manifestFileName

@Nonnull
protected final String manifestFileName

manifestFilePath

@Nonnull
protected final org.apache.flink.core.fs.Path manifestFilePath

previousSnapshot

@Nonnull
protected ForStSnapshotStrategyBase.PreviousSnapshot previousSnapshot

releaser

@Nonnull
protected final Runnable releaser

Constructor Detail

ForStNativeSnapshotResources

public ForStNativeSnapshotResources(@Nonnull
                                    List<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot> stateMetaInfoSnapshots,
                                    long manifestFileSize,
                                    @Nonnull
                                    List<org.apache.flink.core.fs.Path> liveFiles,
                                    @Nonnull
                                    org.apache.flink.core.fs.Path manifestFilePath,
                                    @Nonnull
                                    ForStSnapshotStrategyBase.PreviousSnapshot previousSnapshot,
                                    @Nonnull
                                    Runnable releaser)

Method Detail

setPreviousSnapshot

public void setPreviousSnapshot(@Nonnull
                                ForStSnapshotStrategyBase.PreviousSnapshot previousSnapshot)

getCurrentFileContent

public String getCurrentFileContent()

release

public void release()

Specified by:

release in interface org.apache.flink.runtime.state.SnapshotResources