org.elasticsearch.common.compress.lzf
Class LZFCompressedStreamInput

java.lang.Object
  java.io.InputStream
      org.elasticsearch.common.io.stream.StreamInput
          org.elasticsearch.common.compress.CompressedStreamInput<LZFCompressorContext>
              org.elasticsearch.common.compress.lzf.LZFCompressedStreamInput

All Implemented Interfaces:

Closeable

public class LZFCompressedStreamInput
extends CompressedStreamInput<LZFCompressorContext>

Field Summary

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

context, uncompressed

Constructor Summary

LZFCompressedStreamInput(StreamInput in, com.ning.compress.lzf.ChunkDecoder decoder)

Method Summary

protected void	doClose()
void	readHeader(StreamInput in)
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.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

LZFCompressedStreamInput

public LZFCompressedStreamInput(StreamInput in,
                                com.ning.compress.lzf.ChunkDecoder decoder)
                         throws IOException

Throws:

IOException

Method Detail

readHeader

public void readHeader(StreamInput in)
                throws IOException

Specified by:

readHeader in class CompressedStreamInput<LZFCompressorContext>

Throws:

IOException

uncompress

public 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<LZFCompressorContext>

Throws:

IOException

doClose

protected void doClose()
                throws IOException

Specified by:

doClose in class CompressedStreamInput<LZFCompressorContext>

Throws:

IOException