Class BeamDecoderFactory<T>

    • Constructor Detail

      • BeamDecoderFactory

        public BeamDecoderFactory​(org.apache.beam.sdk.coders.Coder<T> beamCoder)
        Constructor of BeamDecoderFactory.
        Parameters:
        beamCoder - actual Beam coder to use.
    • Method Detail

      • create

        public DecoderFactory.Decoder<T> create​(java.io.InputStream inputStream)
        Description copied from interface: DecoderFactory
        Get a decoder instance.
        Specified by:
        create in interface DecoderFactory<T>
        Parameters:
        inputStream - the input stream to decode.
        Returns:
        the decoder instance.
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object