org.elasticsearch.common.compress.snappy
Class SnappyCompressedStreamInput

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

All Implemented Interfaces:

Closeable

Direct Known Subclasses:

XerialSnappyCompressedStreamInput

public abstract class SnappyCompressedStreamInput
extends CompressedStreamInput<SnappyCompressorContext>

Field Summary

protected int	chunkSize
protected byte[]	inputBuffer
protected int	maxCompressedChunkLength
protected com.ning.compress.BufferRecycler	recycler

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

context, uncompressed

Constructor Summary

SnappyCompressedStreamInput(StreamInput in, SnappyCompressorContext context)

Method Summary

protected void	doClose()
void	readHeader(StreamInput in)

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

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

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

Field Detail

recycler

protected final com.ning.compress.BufferRecycler recycler

chunkSize

protected int chunkSize

maxCompressedChunkLength

protected int maxCompressedChunkLength

inputBuffer

protected byte[] inputBuffer

Constructor Detail

SnappyCompressedStreamInput

public SnappyCompressedStreamInput(StreamInput in,
                                   SnappyCompressorContext context)
                            throws IOException

Throws:

IOException

Method Detail

readHeader

public void readHeader(StreamInput in)
                throws IOException

Specified by:

readHeader in class CompressedStreamInput<SnappyCompressorContext>

Throws:

IOException

doClose

protected void doClose()
                throws IOException

Specified by:

doClose in class CompressedStreamInput<SnappyCompressorContext>

Throws:

IOException