Package org.apache.nemo.compiler.frontend.beam.transform

Class InMemoryStateInternalsFactory<K>

java.lang.Object

org.apache.nemo.compiler.frontend.beam.transform.InMemoryStateInternalsFactory<K>

Type Parameters:

K - key type

All Implemented Interfaces:

org.apache.beam.runners.core.StateInternalsFactory<K>

public final class InMemoryStateInternalsFactory<K>
extends java.lang.Object
implements org.apache.beam.runners.core.StateInternalsFactory<K>

InMemoryStateInternalsFactory.

Constructor Summary

Constructors

Constructor	Description
InMemoryStateInternalsFactory()

Method Summary

Modifier and Type	Method	Description
java.util.Map<K,org.apache.beam.runners.core.StateInternals>	getStateInternalMap()
org.apache.beam.runners.core.StateInternals	stateInternalsForKey(K key)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryStateInternalsFactory

public InMemoryStateInternalsFactory()

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

stateInternalsForKey

public org.apache.beam.runners.core.StateInternals stateInternalsForKey(K key)

Specified by:

stateInternalsForKey in interface org.apache.beam.runners.core.StateInternalsFactory<K>

getStateInternalMap

public java.util.Map<K,org.apache.beam.runners.core.StateInternals> getStateInternalMap()