Class PairDecoderFactory<A extends java.io.Serializable,​B extends java.io.Serializable>

  • Type Parameters:
    A - type for the left coder.
    B - type for the right coder.
    All Implemented Interfaces:
    java.io.Serializable, DecoderFactory<Pair<A,​B>>

    public final class PairDecoderFactory<A extends java.io.Serializable,​B extends java.io.Serializable>
    extends java.lang.Object
    implements DecoderFactory<Pair<A,​B>>
    An DecoderFactory for Pair. Reference: KvCoder in BEAM.
    See Also:
    Serialized Form
    • Method Detail

      • of

        public static <A extends java.io.Serializable,​B extends java.io.Serializable> PairDecoderFactory<A,​B> of​(DecoderFactory<A> leftDecoderFactory,
                                                                                                                             DecoderFactory<B> rightDecoderFactory)
        static initializer of the class.
        Type Parameters:
        A - type of the left element.
        B - type of the right element.
        Parameters:
        leftDecoderFactory - left coder.
        rightDecoderFactory - right coder.
        Returns:
        the new PairDecoderFactory.
      • create

        public DecoderFactory.Decoder<Pair<A,​B>> create​(java.io.InputStream inputStream)
                                                       throws java.io.IOException
        Description copied from interface: DecoderFactory
        Get a decoder instance.
        Specified by:
        create in interface DecoderFactory<A extends java.io.Serializable>
        Parameters:
        inputStream - the input stream to decode.
        Returns:
        the decoder instance.
        Throws:
        java.io.IOException - if fail to get the instance.
      • toString

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