org.apache.flink.runtime.state

Class LocalStateHandle

java.lang.Object

org.apache.flink.runtime.state.LocalStateHandle

All Implemented Interfaces:

Serializable, StateHandle<Serializable>

public class LocalStateHandle
extends Object
implements StateHandle<Serializable>

A StateHandle that includes the operator states directly.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocalStateHandle(Serializable state)

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.runtime.state.LocalStateHandle.LocalStateHandleProvider	createProvider()
void	discardState() Discards the state referred to by this handle, to free up resources in the persistent storage.
Serializable	getState() This retrieves and return the state represented by the handle.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStateHandle

public LocalStateHandle(Serializable state)

Method Detail

getState

public Serializable getState()

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.

discardState

public void discardState()
                  throws Exception

Description copied from interface: StateHandle

Discards the state referred to by this handle, to free up resources in the persistent storage. This method is called when the handle will not be used any more.

Specified by:

discardState in interface StateHandle<Serializable>

Throws:

Exception

createProvider

public static org.apache.flink.runtime.state.LocalStateHandle.LocalStateHandleProvider createProvider()