Class DecoderPassThrough

  • All Implemented Interfaces:
    Externalizable, Serializable

    public class DecoderPassThrough
    extends Decoder
    Simple atomic decoder for passing through numeric columns to the output. This is required for block-wise decoding.
    See Also:
    Serialized Form
    • Constructor Detail

      • DecoderPassThrough

        public DecoderPassThrough()
    • Method Detail

      • decode

        public FrameBlock decode​(MatrixBlock in,
                                 FrameBlock out)
        Description copied from class: Decoder
        Block decode API converting a matrix block into a frame block.
        Specified by:
        decode in class Decoder
        Parameters:
        in - input matrix block
        out - output frame block
        Returns:
        returns given output frame block for convenience
      • subRangeDecoder

        public Decoder subRangeDecoder​(int colStart,
                                       int colEnd,
                                       int dummycodedOffset)
        Description copied from class: Decoder
        Returns a new Decoder that only handles a sub range of columns. The sub-range refers to the columns after decoding.
        Overrides:
        subRangeDecoder in class Decoder
        Parameters:
        colStart - the start index of the sub-range (1-based, inclusive)
        colEnd - the end index of the sub-range (1-based, exclusive)
        dummycodedOffset - the offset of dummycoded segments before colStart
        Returns:
        a decoder of the same type, just for the sub-range
      • writeExternal

        public void writeExternal​(ObjectOutput os)
                           throws IOException
        Description copied from class: Decoder
        Redirects the default java serialization via externalizable to our default hadoop writable serialization for efficient broadcast/rdd serialization.
        Specified by:
        writeExternal in interface Externalizable
        Overrides:
        writeExternal in class Decoder
        Parameters:
        os - object output
        Throws:
        IOException - if IOException occurs
      • readExternal

        public void readExternal​(ObjectInput in)
                          throws IOException
        Description copied from class: Decoder
        Redirects the default java serialization via externalizable to our default hadoop writable serialization for efficient broadcast/rdd deserialization.
        Specified by:
        readExternal in interface Externalizable
        Overrides:
        readExternal in class Decoder
        Parameters:
        in - object input
        Throws:
        IOException - if IOException occur