Package org.elasticsearch.transport

Interface TransportDecompressor

All Superinterfaces:

AutoCloseable, Closeable, 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 IllegalStateException	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 IOException

Decompress the provided bytes

Parameters:

bytesReference - to decompress

Returns:

number of compressed bytes consumed

Throws:

IOException

pollDecompressedPage

ReleasableBytesReference pollDecompressedPage(boolean isEOS)

close

void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable

getDecompressor

static TransportDecompressor getDecompressor(PageCacheRecycler recycler,
 BytesReference bytes)
                                      throws IOException

Throws:

IOException

createIllegalState

static IllegalStateException createIllegalState(BytesReference bytes)