Package org.elasticsearch.transport

Class Lz4TransportDecompressor

java.lang.Object

org.elasticsearch.transport.Lz4TransportDecompressor

All Implemented Interfaces:

Closeable, AutoCloseable, org.elasticsearch.core.Releasable, TransportDecompressor

public class Lz4TransportDecompressor
extends Object
implements TransportDecompressor

This file is forked from the https://netty.io project. In particular it forks the following file io.netty.handler.codec.compression.Lz4FrameDecoder. It modifies the original netty code to operate on byte arrays opposed to ByteBufs. Additionally, it integrates the decompression code to work in the Elasticsearch transport pipeline, Finally, it replaces the custom Netty decoder exceptions. This class is necessary as Netty is not a dependency in Elasticsearch server module.

Constructor Summary

Constructors

Constructor	Description
Lz4TransportDecompressor(PageCacheRecycler recycler)

Method Summary

Modifier and Type	Method	Description
void	close()
int	decompress(BytesReference bytesReference)	Decompress the provided bytes
Compression.Scheme	getScheme()
boolean	isClosed()	Returns true if and only if the end of the compressed stream has been reached.
ReleasableBytesReference	pollDecompressedPage(boolean isEOS)

Methods inherited from class java.lang.Object

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

Constructor Details

Lz4TransportDecompressor

public Lz4TransportDecompressor(PageCacheRecycler recycler)

Method Details

pollDecompressedPage

public ReleasableBytesReference pollDecompressedPage(boolean isEOS)

Specified by:

pollDecompressedPage in interface TransportDecompressor

getScheme

public Compression.Scheme getScheme()

Specified by:

getScheme in interface TransportDecompressor

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable

Specified by:

close in interface TransportDecompressor

decompress

public int decompress(BytesReference bytesReference)
               throws IOException

Description copied from interface: TransportDecompressor

Decompress the provided bytes

Specified by:

decompress in interface TransportDecompressor

Parameters:

bytesReference - to decompress

Returns:

number of compressed bytes consumed

Throws:

IOException

isClosed

public boolean isClosed()

Returns true if and only if the end of the compressed stream has been reached.