org.apache.flink.runtime.state

Class AbstractSnapshotStrategy<T extends StateObject>

java.lang.Object

org.apache.flink.runtime.state.AbstractSnapshotStrategy<T>

Type Parameters:

T - type of the snapshot result.

All Implemented Interfaces:

SnapshotStrategy<SnapshotResult<T>>

Direct Known Subclasses:

RocksDBSnapshotStrategyBase

public abstract class AbstractSnapshotStrategy<T extends StateObject>
extends Object
implements SnapshotStrategy<SnapshotResult<T>>

Abstract base class for implementing SnapshotStrategy, that gives a consistent logging across state backends.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	description Descriptive name of the snapshot strategy that will appear in the log outputs and toString().

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSnapshotStrategy(String description)

Method Summary

Modifier and Type	Method and Description
void	logAsyncCompleted(Object checkpointOutDescription, long startTime) Logs the duration of the asynchronous snapshot part from the given start time.
void	logSyncCompleted(Object checkpointOutDescription, long startTime) Logs the duration of the synchronous snapshot part from the given start time.
String	toString()

Methods inherited from class java.lang.Object

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

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

snapshot

Field Detail

description

@Nonnull
protected final String description

Descriptive name of the snapshot strategy that will appear in the log outputs and toString().

Constructor Detail

AbstractSnapshotStrategy

protected AbstractSnapshotStrategy(@Nonnull
                                   String description)

Method Detail

logSyncCompleted

public void logSyncCompleted(@Nonnull
                             Object checkpointOutDescription,
                             long startTime)

Logs the duration of the synchronous snapshot part from the given start time.

logAsyncCompleted

public void logAsyncCompleted(@Nonnull
                              Object checkpointOutDescription,
                              long startTime)

Logs the duration of the asynchronous snapshot part from the given start time.

toString

public String toString()

Overrides:

toString in class Object