TransportDecompressor (server 7.17.21 API)

All Superinterfaces:: AutoCloseable, Closeable, Releasable

All Known Implementing Classes:: DeflateTransportDecompressor, Lz4TransportDecompressor

public interface TransportDecompressor extends 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)

Compression.Scheme

getScheme()

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)
- getScheme
  
  Compression.Scheme getScheme()
- close
  
  void close()
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Closeable
  
  Specified by:
  
  close in interface Releasable
- getDecompressor
  
  static TransportDecompressor getDecompressor(PageCacheRecycler recycler, BytesReference bytes) throws IOException
  
  Throws:
  
  IOException
- createIllegalState
  
  static IllegalStateException createIllegalState(BytesReference bytes)