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

Class StateAndTimers

  • All Implemented Interfaces:
    java.io.Serializable
    public abstract class StateAndTimers
extends java.lang.Object
implements java.io.Serializable
    State and Timers wrapper.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      StateAndTimers()  

    • Method Summary

      All Methods Static Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      abstract org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,​java.lang.String,​byte[]> getState()  
      abstract java.util.Collection<byte[]> getTimers()  
      static StateAndTimers of​(org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,​java.lang.String,​byte[]> state, java.util.Collection<byte[]> timers)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • StateAndTimers

        public StateAndTimers()

    • Method Detail

      • getState

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

      • getTimers

        public abstract java.util.Collection<byte[]> getTimers()

      • of

        public static StateAndTimers of​(org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Table<java.lang.String,​java.lang.String,​byte[]> state,
                                java.util.Collection<byte[]> timers)