Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator.exchange

Interface BidirectionalBatchExchangeClient.ServerSetupCallback

Enclosing class:

BidirectionalBatchExchangeClient

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface BidirectionalBatchExchangeClient.ServerSetupCallback

Functional interface for server setup callback. Called when a new server connection needs to be established.

Method Summary

Modifier and Type	Method	Description
void	sendSetupRequest(DiscoveryNode serverNode, String clientToServerId, String serverToClientId, ActionListener<String> listener)	Send setup request to the server.

Method Details

sendSetupRequest

void sendSetupRequest(DiscoveryNode serverNode,
 String clientToServerId,
 String serverToClientId,
 ActionListener<String> listener)

Send setup request to the server.

Parameters:

serverNode - the server node to connect to

clientToServerId - the per-server unique client-to-server exchange ID

serverToClientId - the shared server-to-client exchange ID

listener - called with the plan string (nullable) on success, or failure