org.apache.flink.runtime.state

Class OperatorStateCheckpointOutputStream

java.lang.Object

java.io.OutputStream

org.apache.flink.runtime.state.NonClosingCheckpointOutputStream<OperatorStateHandle>

org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

@PublicEvolving
public final class OperatorStateCheckpointOutputStream
extends NonClosingCheckpointOutputStream<OperatorStateHandle>

Checkpoint output stream that allows to write raw operator state in a partitioned way.

Field Summary

Fields inherited from class org.apache.flink.runtime.state.NonClosingCheckpointOutputStream

delegate

Constructor Summary

Constructors

Constructor and Description
OperatorStateCheckpointOutputStream(CheckpointStreamFactory.CheckpointStateOutputStream delegate)

Method Summary

Modifier and Type	Method and Description
int	getNumberOfPartitions()
void	startNewPartition() User code can call this method to signal that it begins to write a new partition of operator state.

Methods inherited from class org.apache.flink.runtime.state.NonClosingCheckpointOutputStream

close, flush, write, write, write

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorStateCheckpointOutputStream

public OperatorStateCheckpointOutputStream(CheckpointStreamFactory.CheckpointStateOutputStream delegate)
                                    throws IOException

Throws:

IOException

Method Detail

startNewPartition

public void startNewPartition()
                       throws IOException

User code can call this method to signal that it begins to write a new partition of operator state. Each previously written partition is considered final/immutable as soon as this method is called again.

Throws:

IOException

getNumberOfPartitions

public int getNumberOfPartitions()