org.elasticsearch.common.compress.lzf
Class LZFCompressedStreamOutput

java.lang.Object
  java.io.OutputStream
      org.elasticsearch.common.io.stream.StreamOutput
          org.elasticsearch.common.compress.CompressedStreamOutput<LZFCompressorContext>
              org.elasticsearch.common.compress.lzf.LZFCompressedStreamOutput

All Implemented Interfaces:

Closeable, Flushable

public class LZFCompressedStreamOutput
extends CompressedStreamOutput<LZFCompressorContext>

Field Summary

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

context, uncompressed, uncompressedLength

Constructor Summary

LZFCompressedStreamOutput(StreamOutput out)

Method Summary

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

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

LZFCompressedStreamOutput

public LZFCompressedStreamOutput(StreamOutput out)
                          throws IOException

Throws:

IOException

Method Detail

writeHeader

public void writeHeader(StreamOutput out)
                 throws IOException

Specified by:

writeHeader in class CompressedStreamOutput<LZFCompressorContext>

Throws:

IOException

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

Throws:

IOException

doClose

protected void doClose()
                throws IOException

Specified by:

doClose in class CompressedStreamOutput<LZFCompressorContext>

Throws:

IOException