org.elasticsearch.common.compress.snappy
Class SnappyCompressedStreamOutput

java.lang.Object
  java.io.OutputStream
      org.elasticsearch.common.io.stream.StreamOutput
          org.elasticsearch.common.compress.CompressedStreamOutput<SnappyCompressorContext>
              org.elasticsearch.common.compress.snappy.SnappyCompressedStreamOutput

All Implemented Interfaces:

Closeable, Flushable

Direct Known Subclasses:

XerialSnappyCompressedStreamOutput

public abstract class SnappyCompressedStreamOutput
extends CompressedStreamOutput<SnappyCompressorContext>

Field Summary

protected byte[]	compressedBuffer
protected com.ning.compress.BufferRecycler	recycler

Fields inherited from class org.elasticsearch.common.compress.CompressedStreamOutput

context, uncompressed, uncompressedLength

Constructor Summary

SnappyCompressedStreamOutput(StreamOutput out, SnappyCompressorContext context)

Method Summary

protected void	doClose()
void	writeHeader(StreamOutput out)

Methods inherited from class org.elasticsearch.common.compress.CompressedStreamOutput

close, compress, flush, reset, write, writeByte, writeBytes

Methods inherited from class org.elasticsearch.common.io.stream.StreamOutput

position, seek, seekPositionSupported, write, writeBoolean, writeBytes, writeBytes, writeBytesReference, writeDouble, writeFloat, writeGenericValue, writeInt, writeLong, writeMap, writeOptionalString, writeOptionalUTF, writeShort, writeString, writeStringArray, writeText, writeUTF, writeVInt, writeVLong

Methods inherited from class java.io.OutputStream

write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

recycler

protected final com.ning.compress.BufferRecycler recycler

compressedBuffer

protected byte[] compressedBuffer

Constructor Detail

SnappyCompressedStreamOutput

public SnappyCompressedStreamOutput(StreamOutput out,
                                    SnappyCompressorContext context)
                             throws IOException

Throws:

IOException

Method Detail

writeHeader

public void writeHeader(StreamOutput out)
                 throws IOException

Specified by:

writeHeader in class CompressedStreamOutput<SnappyCompressorContext>

Throws:

IOException

doClose

protected void doClose()
                throws IOException

Specified by:

doClose in class CompressedStreamOutput<SnappyCompressorContext>

Throws:

IOException