org.apache.beam.runners.spark.stateful

Class SparkStateInternals<K>

java.lang.Object

org.apache.beam.runners.spark.stateful.SparkStateInternals<K>

All Implemented Interfaces:

org.apache.beam.runners.core.StateInternals

public class SparkStateInternals<K>
extends java.lang.Object
implements org.apache.beam.runners.core.StateInternals

An implementation of StateInternals for the SparkRunner.

Method Summary

Modifier and Type	Method and Description
static <K> SparkStateInternals<K>	forKey(K key)
static <K> SparkStateInternals<K>	forKeyAndState(K key, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,java.lang.String,byte[]> stateTable)
K	getKey()
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,java.lang.String,byte[]>	getState()
<T extends State> T	state(org.apache.beam.runners.core.StateNamespace namespace, org.apache.beam.runners.core.StateTag<T> address, StateContext<?> c)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.runners.core.StateInternals

state

Method Detail

forKey

public static <K> SparkStateInternals<K> forKey(K key)

forKeyAndState

public static <K> SparkStateInternals<K> forKeyAndState(K key,
                                                        org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,java.lang.String,byte[]> stateTable)

getState

public org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,java.lang.String,byte[]> getState()

getKey

public K getKey()

Specified by:

getKey in interface org.apache.beam.runners.core.StateInternals

state

public <T extends State> T state(org.apache.beam.runners.core.StateNamespace namespace,
                                 org.apache.beam.runners.core.StateTag<T> address,
                                 StateContext<?> c)

Specified by:

state in interface org.apache.beam.runners.core.StateInternals