org.apache.flink.runtime.state

Class LocalStateHandle<T extends Serializable>

java.lang.Object

org.apache.flink.runtime.state.LocalStateHandle<T>

All Implemented Interfaces:

Serializable, StateHandle<T>

public class LocalStateHandle<T extends Serializable>
extends Object
implements StateHandle<T>

A StateHandle that includes the operator states directly.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocalStateHandle(T state)

Method Summary

Modifier and Type	Method and Description
void	discardState() Discards the state referred to by this handle, to free up resources in the persistent storage.
T	getState(ClassLoader userCodeClassLoader) This retrieves and return the state represented by the handle.
long	getStateSize() Returns the size of the state in bytes.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStateHandle

public LocalStateHandle(T state)

Method Detail

getState

public T getState(ClassLoader userCodeClassLoader)

Description copied from interface: StateHandle

This retrieves and return the state represented by the handle.

Specified by:

getState in interface StateHandle<T extends Serializable>

Parameters:

userCodeClassLoader - Class loader for deserializing user code specific classes

Returns:

The state represented by the handle.

discardState

public void discardState()

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<T extends Serializable>

getStateSize

public long getStateSize()

Description copied from interface: StateHandle

Returns the size of the state in bytes.

If the the size is not known, return 0.

Specified by:

getStateSize in interface StateHandle<T extends Serializable>

Returns:

Size of the state in bytes.