org.apache.flink.runtime.state

Class ByteStreamStateHandle

java.lang.Object

org.apache.flink.runtime.state.ByteStreamStateHandle

All Implemented Interfaces:

Serializable, StateHandle<Serializable>

Direct Known Subclasses:

FileStateHandle

public abstract class ByteStreamStateHandle
extends Object
implements StateHandle<Serializable>

Statehandle that writes/reads the contents of the serializable checkpointed state to the provided input and outputstreams using default java serialization.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ByteStreamStateHandle(Serializable state)

Method Summary

Modifier and Type	Method and Description
protected abstract InputStream	getInputStream() The state will be read from the stream returned by this method.
protected abstract OutputStream	getOutputStream() The state will be written to the stream returned by this method.
Serializable	getState() This retrieves and return the state represented by the handle.
boolean	stateFetched() Checks whether the state has already been fetched from the remote storage.

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.StateHandle

discardState

Constructor Detail

ByteStreamStateHandle

public ByteStreamStateHandle(Serializable state)

Method Detail

getOutputStream

protected abstract OutputStream getOutputStream()
                                         throws Exception

The state will be written to the stream returned by this method.

Throws:

Exception

getInputStream

protected abstract InputStream getInputStream()
                                       throws Exception

The state will be read from the stream returned by this method.

Throws:

Exception

getState

public Serializable getState()
                      throws Exception

Description copied from interface: StateHandle

This retrieves and return the state represented by the handle.

Specified by:

getState in interface StateHandle<Serializable>

Returns:

The state represented by the handle.

Throws:

Exception - Thrown, if the state cannot be fetched.

stateFetched

public boolean stateFetched()

Checks whether the state has already been fetched from the remote storage.