Package org.elasticsearch.transport

Interface TransportDecompressor

All Superinterfaces:

, , org.elasticsearch.core.Releasable

All Known Implementing Classes:

DeflateTransportDecompressor, Lz4TransportDecompressor

public interface TransportDecompressor
extends org.elasticsearch.core.Releasable

Method Summary

Modifier and Type	Method	Description
void	close()
static	createIllegalState(BytesReference bytes)
int	decompress(BytesReference bytesReference)	Decompress the provided bytes
static TransportDecompressor	getDecompressor(PageCacheRecycler recycler, BytesReference bytes)
ReleasableBytesReference	pollDecompressedPage(boolean isEOS)

Method Details

decompress

int decompress(BytesReference bytesReference)
        throws 

Decompress the provided bytes

Parameters:

bytesReference - to decompress

Returns:

number of compressed bytes consumed

Throws:

pollDecompressedPage

ReleasableBytesReference pollDecompressedPage(boolean isEOS)

close

void close()

Specified by:

in interface

Specified by:

in interface

Specified by:

close in interface org.elasticsearch.core.Releasable

getDecompressor

static TransportDecompressor getDecompressor(PageCacheRecycler recycler,
 BytesReference bytes)
                                      throws 

Throws:

createIllegalState

static  createIllegalState(BytesReference bytes)