org.apache.flink.runtime.state

Interface StateSnapshotContext

All Superinterfaces:

FunctionSnapshotContext, ManagedSnapshotContext

All Known Implementing Classes:

StateSnapshotContextSynchronousImpl

@PublicEvolving
public interface StateSnapshotContext
extends FunctionSnapshotContext

This interface provides a context in which operators that use managed (i.e. state that is managed by state backends) or raw (i.e. the operator can write it's state streams) state can perform a snapshot.

Method Summary

Modifier and Type	Method and Description
KeyedStateCheckpointOutputStream	getRawKeyedOperatorStateOutput() Returns an output stream for keyed state
OperatorStateCheckpointOutputStream	getRawOperatorStateOutput() Returns an output stream for operator state

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

getCheckpointId, getCheckpointTimestamp

Method Detail

getRawKeyedOperatorStateOutput

KeyedStateCheckpointOutputStream getRawKeyedOperatorStateOutput()
                                                         throws Exception

Returns an output stream for keyed state

Throws:

Exception

getRawOperatorStateOutput

OperatorStateCheckpointOutputStream getRawOperatorStateOutput()
                                                       throws Exception

Returns an output stream for operator state

Throws:

Exception