Class SideInputCoder<T>

  • Type Parameters:
    T - type of the side input value.
    All Implemented Interfaces:
    Serializable

    public final class SideInputCoder<T>
    extends org.apache.beam.sdk.coders.StructuredCoder<SideInputElement<T>>
    EncoderFactory for side inputs.
    See Also:
    Serialized Form
    • Method Detail

      • of

        public static SideInputCoder of​(org.apache.beam.sdk.coders.Coder valueCoder)
        Parameters:
        valueCoder - the coder for side input.
        Returns:
        a new coder
      • getCoderArguments

        public List<? extends org.apache.beam.sdk.coders.Coder<?>> getCoderArguments()
        Specified by:
        getCoderArguments in class org.apache.beam.sdk.coders.Coder<SideInputElement<T>>
      • verifyDeterministic

        public void verifyDeterministic()
                                 throws org.apache.beam.sdk.coders.Coder.NonDeterministicException
        Specified by:
        verifyDeterministic in class org.apache.beam.sdk.coders.Coder<SideInputElement<T>>
        Throws:
        org.apache.beam.sdk.coders.Coder.NonDeterministicException