org.apache.arrow.flight

Class NoOpFlightProducer

java.lang.Object

org.apache.arrow.flight.NoOpFlightProducer

All Implemented Interfaces:

FlightProducer

Direct Known Subclasses:

IntegrationProducer

public class NoOpFlightProducer
extends Object
implements FlightProducer

A FlightProducer that throws on all operations.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.flight.FlightProducer

FlightProducer.CallContext, FlightProducer.ServerStreamListener, FlightProducer.StreamListener<T>

Constructor Summary

Constructors

Constructor and Description
NoOpFlightProducer()

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.
FlightInfo	getFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor) Get information about 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.arrow.flight.FlightProducer

doExchange, getSchema, pollFlightInfo

Constructor Detail

NoOpFlightProducer

public NoOpFlightProducer()

Method Detail

getStream

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

Description copied from interface: FlightProducer

Return data for a stream.

Specified by:

getStream in interface FlightProducer

Parameters:

context - Per-call context.

ticket - The application-defined ticket identifying this stream.

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

listFlights

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

Description copied from interface: FlightProducer

List available data streams on this service.

Specified by:

listFlights in interface FlightProducer

Parameters:

context - Per-call context.

criteria - Application-defined criteria for filtering streams.

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

getFlightInfo

public FlightInfo getFlightInfo(FlightProducer.CallContext context,
                                FlightDescriptor descriptor)

Description copied from interface: FlightProducer

Get information about a particular data stream.

Specified by:

getFlightInfo in interface FlightProducer

Parameters:

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

acceptPut

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

Description copied from interface: FlightProducer

Accept uploaded data for a particular stream.

Specified by:

acceptPut in interface FlightProducer

Parameters:

context - Per-call context.

flightStream - The data stream being uploaded.

doAction

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

Description copied from interface: FlightProducer

Generic handler for application-defined RPCs.

Specified by:

doAction in interface FlightProducer

Parameters:

context - Per-call context.

action - Client-supplied parameters.

listener - A stream of responses.

listActions

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

Description copied from interface: FlightProducer

List available application-defined RPCs.

Specified by:

listActions in interface FlightProducer

Parameters:

context - Per-call context.

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