Runnable |
FlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accept uploaded data for a particular stream.
|
Runnable |
NoOpFlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
void |
FlightProducer.doAction(FlightProducer.CallContext context,
Action action,
FlightProducer.StreamListener<Result> listener)
Generic handler for application-defined RPCs.
|
void |
NoOpFlightProducer.doAction(FlightProducer.CallContext context,
Action action,
FlightProducer.StreamListener<Result> listener) |
default void |
FlightProducer.doExchange(FlightProducer.CallContext context,
FlightStream reader,
FlightProducer.ServerStreamListener writer) |
FlightInfo |
FlightProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get information about a particular data stream.
|
FlightInfo |
NoOpFlightProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor) |
default SchemaResult |
FlightProducer.getSchema(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get schema for a particular data stream.
|
void |
FlightProducer.getStream(FlightProducer.CallContext context,
Ticket ticket,
FlightProducer.ServerStreamListener listener)
Return data for a stream.
|
void |
NoOpFlightProducer.getStream(FlightProducer.CallContext context,
Ticket ticket,
FlightProducer.ServerStreamListener listener) |
void |
FlightProducer.listActions(FlightProducer.CallContext context,
FlightProducer.StreamListener<ActionType> listener)
List available application-defined RPCs.
|
void |
NoOpFlightProducer.listActions(FlightProducer.CallContext context,
FlightProducer.StreamListener<ActionType> listener) |
void |
FlightProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener)
List available data streams on this service.
|
void |
NoOpFlightProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener) |