org.apache.flink.state.api.output

Class SnapshotUtils

java.lang.Object

org.apache.flink.state.api.output.SnapshotUtils

@Internal
public final class SnapshotUtils
extends Object

Takes a final snapshot of the state of an operator subtask.

Method Summary

Modifier and Type	Method and Description
static <OUT,OP extends StreamOperator<OUT>> TaggedOperatorSubtaskState	snapshot(OP operator, int index, long timestamp, boolean isExactlyOnceMode, boolean isUnalignedCheckpoint, Configuration configuration, Path savepointPath)
static <OUT,OP extends StreamOperator<OUT>> TaggedOperatorSubtaskState	snapshot(OP operator, int index, long timestamp, boolean isExactlyOnceMode, boolean isUnalignedCheckpoint, Configuration configuration, Path savepointPath, SavepointFormatType savepointFormatType)

Methods inherited from class java.lang.Object

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

Method Detail

snapshot

public static <OUT,OP extends StreamOperator<OUT>> TaggedOperatorSubtaskState snapshot(OP operator,
                                                                                       int index,
                                                                                       long timestamp,
                                                                                       boolean isExactlyOnceMode,
                                                                                       boolean isUnalignedCheckpoint,
                                                                                       Configuration configuration,
                                                                                       Path savepointPath,
                                                                                       SavepointFormatType savepointFormatType)
                                                                                throws Exception

Throws:

Exception

snapshot

public static <OUT,OP extends StreamOperator<OUT>> TaggedOperatorSubtaskState snapshot(OP operator,
                                                                                       int index,
                                                                                       long timestamp,
                                                                                       boolean isExactlyOnceMode,
                                                                                       boolean isUnalignedCheckpoint,
                                                                                       Configuration configuration,
                                                                                       Path savepointPath)
                                                                                throws Exception

Throws:

Exception