Package org.elasticsearch.transport

Class DeflateTransportDecompressor

java.lang.Object

org.elasticsearch.transport.DeflateTransportDecompressor

All Implemented Interfaces:

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

public class DeflateTransportDecompressor
extends Object
implements TransportDecompressor

Constructor Summary

Constructors

Constructor	Description
DeflateTransportDecompressor(PageCacheRecycler recycler)

Method Summary

Modifier and Type	Method	Description
void	close()
int	decompress(BytesReference bytesReference)	Decompress the provided bytes
boolean	isEOS()
ReleasableBytesReference	pollDecompressedPage(boolean isEOS)

Methods inherited from class java.lang.Object

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

Constructor Details

DeflateTransportDecompressor

public DeflateTransportDecompressor(PageCacheRecycler recycler)

Method Details

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

isEOS

public boolean isEOS()

pollDecompressedPage

public ReleasableBytesReference pollDecompressedPage(boolean isEOS)

Specified by:

pollDecompressedPage 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