Module org.elasticsearch.server

Package org.elasticsearch.search.fetch.chunk

Class TransportFetchPhaseResponseChunkAction

java.lang.Object

org.elasticsearch.search.fetch.chunk.TransportFetchPhaseResponseChunkAction

public class TransportFetchPhaseResponseChunkAction
extends Object

Receives fetch result chunks from data nodes via zero-copy transport. This component runs on the coordinator node and serves as the receiver endpoint for FetchPhaseResponseChunk messages sent by data nodes during chunked fetch operations.

Chunks arrive as BytesTransportRequest on the ZERO_COPY_ACTION_NAME endpoint. Bytes flow directly from Netty buffers without an intermediate deserialization/re-serialization step.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ZERO_COPY_ACTION_NAME	Action name for zero-copy BytesTransportRequest path.

Constructor Summary

Constructors

Constructor	Description
TransportFetchPhaseResponseChunkAction(TransportService transportService, ActiveFetchPhaseTasks activeFetchPhaseTasks, NamedWriteableRegistry namedWriteableRegistry)	Creates a new chunk receiver and registers the zero-copy transport handler.

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

ZERO_COPY_ACTION_NAME

public static final String ZERO_COPY_ACTION_NAME

Action name for zero-copy BytesTransportRequest path. Sender uses this action name when sending via BytesTransportRequest.

See Also:

• Constant Field Values

Constructor Details

TransportFetchPhaseResponseChunkAction

@Inject
public TransportFetchPhaseResponseChunkAction(TransportService transportService,
 ActiveFetchPhaseTasks activeFetchPhaseTasks,
 NamedWriteableRegistry namedWriteableRegistry)

Creates a new chunk receiver and registers the zero-copy transport handler.

Parameters:

transportService - the transport service used to register the handler

activeFetchPhaseTasks - the registry of active fetch response streams

namedWriteableRegistry - registry for deserializing NamedWriteable types in chunks