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.
|
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 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 © 2023 The Apache Software Foundation. All rights reserved.