Class ProcessBundleDescriptors.SideInputSpec<T,W extends BoundedWindow>

java.lang.Object
org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.SideInputSpec<T,W>
Enclosing class:
ProcessBundleDescriptors

public abstract static class ProcessBundleDescriptors.SideInputSpec<T,W extends BoundedWindow> extends Object
A container type storing references to the value, and window Coder used when handling side input state requests.
  • Constructor Details

    • SideInputSpec

      public SideInputSpec()
  • Method Details

    • of

      public static <T, W extends BoundedWindow> ProcessBundleDescriptors.SideInputSpec of(String transformId, String sideInputId, org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern, Coder<T> elementCoder, Coder<W> windowCoder)
    • transformId

      public abstract String transformId()
    • sideInputId

      public abstract String sideInputId()
    • accessPattern

      public abstract org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern()
    • elementCoder

      public abstract Coder<T> elementCoder()
    • windowCoder

      public abstract Coder<W> windowCoder()