Package org.apache.beam.runners.spark.stateful

Class 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

      All Methods Static Methods Instance Methods Concrete Methods 
      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<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 org.apache.beam.sdk.state.State>
      T      		 state​(org.apache.beam.runners.core.StateNamespace namespace, org.apache.beam.runners.core.StateTag<T> address, org.apache.beam.sdk.state.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

      • 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 org.apache.beam.sdk.state.State> T state​(org.apache.beam.runners.core.StateNamespace namespace,
                                                           org.apache.beam.runners.core.StateTag<T> address,
                                                           org.apache.beam.sdk.state.StateContext<?> c)
        Specified by:
        state in interface org.apache.beam.runners.core.StateInternals