org.apache.flink.runtime.state

Class LocalStateHandle

java.lang.Object

org.apache.flink.runtime.state.LocalStateHandle

All Implemented Interfaces:

Serializable, StateHandle

public class LocalStateHandle
extends Object
implements StateHandle

A StateHandle that includes a copy of the state itself. This state handle is recommended for cases where the operatorState is lightweight enough to pass throughout the network. State is kept in a byte[] because it may contain userclasses, which akka is not able to handle.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocalStateHandle(Map<String,OperatorState<?>> state)

Method Summary

Modifier and Type	Method and Description
Map<String,OperatorState<?>>	getState(ClassLoader usercodeClassloader) getState should retrieve and return the state managed 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(Map<String,OperatorState<?>> state)
                 throws IOException

Throws:

IOException

Method Detail

getState

public Map<String,OperatorState<?>> getState(ClassLoader usercodeClassloader)

Description copied from interface: StateHandle

getState should retrieve and return the state managed the handle.

Specified by:

getState in interface StateHandle

Returns: