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

java.lang.Object
  java.io.InputStream
      org.elasticsearch.common.io.stream.StreamInput
          org.elasticsearch.common.compress.CompressedStreamInput<SnappyCompressorContext>
              org.elasticsearch.common.compress.snappy.SnappyCompressedStreamInput
                  org.elasticsearch.common.compress.snappy.xerial.XerialSnappyCompressedStreamInput

All Implemented Interfaces:

Closeable

public class XerialSnappyCompressedStreamInput
extends SnappyCompressedStreamInput

Field Summary

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

chunkSize, inputBuffer, maxCompressedChunkLength, recycler

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

context, uncompressed

Constructor Summary

XerialSnappyCompressedStreamInput(StreamInput in, SnappyCompressorContext context)

Method Summary

protected int

uncompress(StreamInput in, byte[] out) Uncompress the data into the out array, returning the size uncompressed

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

doClose, readHeader

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

available, close, read, read, read, readByte, readBytes, readyBuffer, reset, resetToBufferStart

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

readBoolean, readBytesReference, readBytesReference, readDouble, readFloat, readFully, readGenericValue, readInt, readLong, readMap, readOptionalString, readOptionalUTF, readShort, readString, readStringArray, readText, readUTF, readVInt, readVLong

Methods inherited from class java.io.InputStream

mark, markSupported, read, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

XerialSnappyCompressedStreamInput

public XerialSnappyCompressedStreamInput(StreamInput in,
                                         SnappyCompressorContext context)
                                  throws IOException

Throws:

IOException

Method Detail

uncompress

protected int uncompress(StreamInput in,
                         byte[] out)
                  throws IOException

Description copied from class: CompressedStreamInput

Uncompress the data into the out array, returning the size uncompressed

Specified by:

uncompress in class CompressedStreamInput<SnappyCompressorContext>

Throws:

IOException