org.apache.arrow.flight

Interface FlightProducer

All Known Implementing Classes:

InMemoryStore, NoOpFlightProducer

public interface FlightProducer

API to Implement an Arrow Flight producer.

Nested Class Summary

Nested Classes

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.

Method Summary

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.

Method Detail

getStream

void getStream(FlightProducer.CallContext context,
               Ticket ticket,
               FlightProducer.ServerStreamListener listener)

Return data for a stream.

Parameters:

context - Per-call context.

ticket - The application-defined ticket identifying this stream.

listener - An interface for sending data back to the client.

listFlights

void listFlights(FlightProducer.CallContext context,
                 Criteria criteria,
                 FlightProducer.StreamListener<FlightInfo> listener)

List available data streams on this service.

Parameters:

context - Per-call context.

criteria - Application-defined criteria for filtering streams.

listener - An interface for sending data back to the client.

getFlightInfo

FlightInfo getFlightInfo(FlightProducer.CallContext context,
                         FlightDescriptor descriptor)

Get information about a particular data stream.

Parameters:

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getSchema

default SchemaResult getSchema(FlightProducer.CallContext context,
                               FlightDescriptor descriptor)

Get schema for a particular data stream.

Parameters:

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Schema for the stream.

acceptPut

Runnable acceptPut(FlightProducer.CallContext context,
                   FlightStream flightStream,
                   FlightProducer.StreamListener<PutResult> ackStream)

Accept uploaded data for a particular stream.

Parameters:

context - Per-call context.

flightStream - The data stream being uploaded.

doExchange

default void doExchange(FlightProducer.CallContext context,
                        FlightStream reader,
                        FlightProducer.ServerStreamListener writer)

doAction

void doAction(FlightProducer.CallContext context,
              Action action,
              FlightProducer.StreamListener<Result> listener)

Generic handler for application-defined RPCs.

Parameters:

context - Per-call context.

action - Client-supplied parameters.

listener - A stream of responses.

listActions

void listActions(FlightProducer.CallContext context,
                 FlightProducer.StreamListener<ActionType> listener)

List available application-defined RPCs.

Parameters:

context - Per-call context.

listener - An interface for sending data back to the client.