public interface FlightProducer
Modifier and Type | Interface and Description |
---|---|
static interface |
FlightProducer.CallContext
Call-specific context.
|
static interface |
FlightProducer.ServerStreamListener
An interface for sending Arrow data back to a client.
|
static interface |
FlightProducer.StreamListener<T>
Callbacks for pushing objects to a receiver.
|
Modifier and Type | Method and Description |
---|---|
Runnable |
acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accept uploaded data for a particular stream.
|
void |
doAction(FlightProducer.CallContext context,
Action action,
FlightProducer.StreamListener<Result> listener)
Generic handler for application-defined RPCs.
|
default void |
doExchange(FlightProducer.CallContext context,
FlightStream reader,
FlightProducer.ServerStreamListener writer) |
FlightInfo |
getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get information about a particular data stream.
|
default SchemaResult |
getSchema(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get schema for a particular data stream.
|
void |
getStream(FlightProducer.CallContext context,
Ticket ticket,
FlightProducer.ServerStreamListener listener)
Return data for a stream.
|
void |
listActions(FlightProducer.CallContext context,
FlightProducer.StreamListener<ActionType> listener)
List available application-defined RPCs.
|
void |
listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener)
List available data streams on this service.
|
default PollInfo |
pollFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Begin or get an update on execution of a long-running query.
|
void getStream(FlightProducer.CallContext context, Ticket ticket, FlightProducer.ServerStreamListener listener)
context
- Per-call context.ticket
- The application-defined ticket identifying this stream.listener
- An interface for sending data back to the client.void listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener)
context
- Per-call context.criteria
- Application-defined criteria for filtering streams.listener
- An interface for sending data back to the client.FlightInfo getFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor)
context
- Per-call context.descriptor
- The descriptor identifying the data stream.default PollInfo pollFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor)
If the descriptor would begin a query, the server should return a response immediately to not block the client. Otherwise, the server should not return an update until progress is made to not spam the client with inactionable updates.
context
- Per-call context.descriptor
- The descriptor identifying the data stream.default SchemaResult getSchema(FlightProducer.CallContext context, FlightDescriptor descriptor)
context
- Per-call context.descriptor
- The descriptor identifying the data stream.Runnable acceptPut(FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
context
- Per-call context.flightStream
- The data stream being uploaded.default void doExchange(FlightProducer.CallContext context, FlightStream reader, FlightProducer.ServerStreamListener writer)
void doAction(FlightProducer.CallContext context, Action action, FlightProducer.StreamListener<Result> listener)
context
- Per-call context.action
- Client-supplied parameters.listener
- A stream of responses.void listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener)
context
- Per-call context.listener
- An interface for sending data back to the client.Copyright © 2024 The Apache Software Foundation. All rights reserved.