Package org.elasticsearch.transport

Class TransportDecompressor

java.lang.Object

org.elasticsearch.transport.TransportDecompressor

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class TransportDecompressor
extends java.lang.Object
implements java.io.Closeable

Constructor Summary

Constructors

Constructor	Description
TransportDecompressor(PageCacheRecycler recycler)

Method Summary

Modifier and Type	Method	Description
boolean	canDecompress(int bytesAvailable)
void	close()
int	decompress(BytesReference bytesReference)
boolean	isEOS()
ReleasableBytesReference	pollDecompressedPage()

Methods inherited from class java.lang.Object

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

Constructor Details

TransportDecompressor

public TransportDecompressor(PageCacheRecycler recycler)

Method Details

decompress

public int decompress(BytesReference bytesReference) throws java.io.IOException

Throws:

java.io.IOException

canDecompress

public boolean canDecompress(int bytesAvailable)

isEOS

public boolean isEOS()

pollDecompressedPage

public ReleasableBytesReference pollDecompressedPage()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable