Class ProcessBundleDescriptors.BagUserStateSpec<K,V,W extends BoundedWindow>

java.lang.Object
org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.BagUserStateSpec<K,V,W>
Enclosing class:
ProcessBundleDescriptors

public abstract static class ProcessBundleDescriptors.BagUserStateSpec<K,V,W extends BoundedWindow> extends Object
A container type storing references to the key, value, and window Coder used when handling bag user state requests.
  • Constructor Details

    • BagUserStateSpec

      public BagUserStateSpec()
  • Method Details

    • transformId

      public abstract String transformId()
    • userStateId

      public abstract String userStateId()
    • keyCoder

      public abstract Coder<K> keyCoder()
    • valueCoder

      public abstract Coder<V> valueCoder()
    • windowCoder

      public abstract Coder<W> windowCoder()