org.elasticsearch.common.compress.snappy.xerial
Class XerialSnappyCompressedStreamOutput

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

All Implemented Interfaces:

Closeable, Flushable

public class XerialSnappyCompressedStreamOutput
extends SnappyCompressedStreamOutput

Field Summary

Fields inherited from class org.elasticsearch.common.compress.snappy.SnappyCompressedStreamOutput

compressedBuffer, recycler

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

context, uncompressed, uncompressedLength

Constructor Summary

XerialSnappyCompressedStreamOutput(StreamOutput out, SnappyCompressorContext context)

Method Summary

protected void

compress(byte[] data, int offset, int len, StreamOutput out) Compresses the data into the output

Methods inherited from class org.elasticsearch.common.compress.snappy.SnappyCompressedStreamOutput

doClose, writeHeader

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

close, 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

Constructor Detail

XerialSnappyCompressedStreamOutput

public XerialSnappyCompressedStreamOutput(StreamOutput out,
                                          SnappyCompressorContext context)
                                   throws IOException

Throws:

IOException

Method Detail

compress

protected void compress(byte[] data,
                        int offset,
                        int len,
                        StreamOutput out)
                 throws IOException

Description copied from class: CompressedStreamOutput

Compresses the data into the output

Specified by:

compress in class CompressedStreamOutput<SnappyCompressorContext>

Throws:

IOException