Package org.elasticsearch.transport

Class DeflateTransportDecompressor

org.elasticsearch.transport.DeflateTransportDecompressor

All Implemented Interfaces:

, , org.elasticsearch.core.Releasable, TransportDecompressor

public class DeflateTransportDecompressor
extends 
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.

, , , , , , , , , ,

Constructor Details

DeflateTransportDecompressor

public DeflateTransportDecompressor(PageCacheRecycler recycler)

Method Details

decompress

public int decompress(BytesReference bytesReference)
               throws 

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:

isEOS

public boolean isEOS()

pollDecompressedPage

public ReleasableBytesReference pollDecompressedPage(boolean isEOS)

Specified by:

pollDecompressedPage in interface TransportDecompressor

close

public void close()

Specified by:

in interface

Specified by:

in interface

Specified by:

close in interface org.elasticsearch.core.Releasable

Specified by:

close in interface TransportDecompressor