Package org.elasticsearch.xpack.esql.datasource.grpc

Class FlightSplit

java.lang.Object

org.elasticsearch.xpack.esql.datasource.grpc.FlightSplit

All Implemented Interfaces:

NamedWriteable, Writeable, ExternalSplit

public class FlightSplit
extends Object
implements ExternalSplit

An ExternalSplit representing a single Arrow Flight endpoint. The ticketBytes field is an opaque token returned by the Flight server inside a FlightEndpoint. It is not data — it is the server's handle for identifying which stream to serve when the client calls DoGet(Ticket). Typical tickets are short (UUIDs, query IDs, encoded partition references — tens to hundreds of bytes). The constructor enforces a MAX_TICKET_SIZE cap to prevent oversized tokens from being shipped across the cluster.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field	Description
static final NamedWriteableRegistry.Entry	ENTRY

Constructor Summary

Constructors

Constructor	Description
FlightSplit(byte[] ticketBytes, String location, long estimatedRows)
FlightSplit(StreamInput in)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
long	estimatedRows()
long	estimatedSizeInBytes()
String	getWriteableName()
int	hashCode()
String	location()
String	sourceType()
byte[]	ticketBytes()
String	toString()
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

ENTRY

public static final NamedWriteableRegistry.Entry ENTRY

Constructor Details

FlightSplit

public FlightSplit(byte[] ticketBytes,
 String location,
 long estimatedRows)

FlightSplit

public FlightSplit(StreamInput in)
            throws IOException

Throws:

IOException

Method Details

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Writeable

Throws:

IOException

getWriteableName

public String getWriteableName()

Specified by:

getWriteableName in interface NamedWriteable

sourceType

public String sourceType()

Specified by:

sourceType in interface ExternalSplit

estimatedSizeInBytes

public long estimatedSizeInBytes()

Specified by:

estimatedSizeInBytes in interface ExternalSplit

ticketBytes

public byte[] ticketBytes()

location

public String location()

estimatedRows

public long estimatedRows()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object