org.apache.flink.runtime.state

Class CheckpointStreamWithResultProvider.PrimaryStreamOnly

java.lang.Object

org.apache.flink.runtime.state.CheckpointStreamWithResultProvider.PrimaryStreamOnly

All Implemented Interfaces:

Closeable, AutoCloseable, CheckpointStreamWithResultProvider

Enclosing interface:

CheckpointStreamWithResultProvider

public static class CheckpointStreamWithResultProvider.PrimaryStreamOnly
extends Object
implements CheckpointStreamWithResultProvider

Implementation of CheckpointStreamWithResultProvider that only creates the primary/remote/jm-owned state.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.CheckpointStreamWithResultProvider

CheckpointStreamWithResultProvider.KeyedStateHandleFactory, CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream, CheckpointStreamWithResultProvider.PrimaryStreamOnly

Field Summary

Fields inherited from interface org.apache.flink.runtime.state.CheckpointStreamWithResultProvider

LOG

Constructor Summary

Constructors

Constructor and Description
PrimaryStreamOnly(CheckpointStateOutputStream outputStream)

Method Summary

Modifier and Type	Method and Description
SnapshotResult<StreamStateHandle>	closeAndFinalizeCheckpointStreamResult() Closes the stream ans returns a snapshot result with the stream handle(s).
CheckpointStateOutputStream	getCheckpointOutputStream() Returns the encapsulated output stream.

Methods inherited from class java.lang.Object

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

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

close, createDuplicatingStream, createSimpleStream, toKeyedStateHandleSnapshotResult

Constructor Detail

PrimaryStreamOnly

public PrimaryStreamOnly(@Nonnull
                         CheckpointStateOutputStream outputStream)

Method Detail

closeAndFinalizeCheckpointStreamResult

@Nonnull
public SnapshotResult<StreamStateHandle> closeAndFinalizeCheckpointStreamResult()
                                                                                  throws IOException

Description copied from interface: CheckpointStreamWithResultProvider

Closes the stream ans returns a snapshot result with the stream handle(s).

Specified by:

closeAndFinalizeCheckpointStreamResult in interface CheckpointStreamWithResultProvider

Throws:

IOException

getCheckpointOutputStream

@Nonnull
public CheckpointStateOutputStream getCheckpointOutputStream()

Description copied from interface: CheckpointStreamWithResultProvider

Returns the encapsulated output stream.

Specified by:

getCheckpointOutputStream in interface CheckpointStreamWithResultProvider