Class CompressedWriteBlock

  • All Implemented Interfaces:
    Comparable<CompressedWriteBlock>, org.apache.hadoop.io.Writable, org.apache.hadoop.io.WritableComparable<CompressedWriteBlock>

    public class CompressedWriteBlock
    extends Object
    implements org.apache.hadoop.io.WritableComparable<CompressedWriteBlock>
    Write block for serializing either a instance of MatrixBlock or CompressedMatrixBlock, To allow spark to read in either or.
    • Constructor Detail

      • CompressedWriteBlock

        public CompressedWriteBlock()
        Write block used to point to a underlying instance of CompressedMatrixBlock or MatrixBlock, Unfortunately spark require a specific object type to serialize therefore we use this class.
      • CompressedWriteBlock

        public CompressedWriteBlock​(MatrixBlock mb)