Module org.elasticsearch.server
Package org.elasticsearch.search.fetch.chunk

Interface FetchPhaseResponseChunk.Writer

Enclosing class:
FetchPhaseResponseChunk
public static interface FetchPhaseResponseChunk.Writer
Interface for sending chunk responses from the data node to the coordinator.

Implementations handle network transport using BytesTransportRequest for zero-copy transmission, and provide buffer allocation using Netty's pooled allocator.

  • Method Details

    • writeResponseChunk

      void writeResponseChunk(FetchPhaseResponseChunk responseChunk, ActionListener<Void> listener)
      Sends a chunk to the coordinator using zero-copy transport.
      Parameters:
      responseChunk - the chunk to send
      listener - called when the chunk is acknowledged or fails

    • newNetworkBytesStream

      RecyclerBytesStreamOutput newNetworkBytesStream()
      Creates a new byte stream for serializing hits. Uses a network buffer pool for efficient allocation.
      Returns:
      a new RecyclerBytesStreamOutput from the network buffer pool