SparkStateInternals (Apache Beam 2.67.0)

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 Object implements org.apache.beam.runners.core.StateInternals

An implementation of StateInternals for the SparkRunner.

Method Summary

Modifier and Type

Method

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<String,String,byte[]> stateTable)

K

getKey()

org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<String,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 Details
- 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<String,String,byte[]> stateTable)
- getState
  
  public org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<String,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