Class SnappyHadoopCompatibleOutputStream

java.lang.Object
java.io.OutputStream
org.xerial.snappy.SnappyOutputStream
org.xerial.snappy.SnappyHadoopCompatibleOutputStream
All Implemented Interfaces:
Closeable, Flushable, AutoCloseable

public class SnappyHadoopCompatibleOutputStream extends SnappyOutputStream
  • Constructor Details

    • SnappyHadoopCompatibleOutputStream

      public SnappyHadoopCompatibleOutputStream(OutputStream out)
    • SnappyHadoopCompatibleOutputStream

      public SnappyHadoopCompatibleOutputStream(OutputStream out, int blockSize)
  • Method Details

    • writeHeader

      protected int writeHeader()
      Overrides:
      writeHeader in class SnappyOutputStream
    • writeBlockPreemble

      protected void writeBlockPreemble()
      Description copied from class: SnappyOutputStream
      Optionally write a preemble before a block. Hadoop requires the actual block data size being written. This base implementation does nothing. Derive implementation can call writeCurrentDataSize().
      Overrides:
      writeBlockPreemble in class SnappyOutputStream