Uses of Interface
org.apache.arrow.flight.FlightProducer.ServerStreamListener

Packages that use FlightProducer.ServerStreamListener

Package	Description
org.apache.arrow.flight
org.apache.arrow.flight.sql

Uses of FlightProducer.ServerStreamListener in org.apache.arrow.flight

Methods in org.apache.arrow.flight with parameters of type FlightProducer.ServerStreamListener

Modifier and Type	Method	Description
default void	FlightProducer.doExchange(FlightProducer.CallContext context, FlightStream reader, FlightProducer.ServerStreamListener writer)	This method is used to perform a bidirectional data exchange between a client and a server.
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	BackpressureStrategy.CallbackBackpressureStrategy.register(FlightProducer.ServerStreamListener listener)
void	BackpressureStrategy.register(FlightProducer.ServerStreamListener listener)	Set up operations to work against the given listener.
protected boolean	BackpressureStrategy.CallbackBackpressureStrategy.shouldContinueWaiting(FlightProducer.ServerStreamListener listener, long remainingTimeout)	Callback function to run to check if the listener should continue to be waited on if it leaves the waiting state without being cancelled, ready, or timed out.

Uses of FlightProducer.ServerStreamListener in org.apache.arrow.flight.sql

Methods in org.apache.arrow.flight.sql with parameters of type FlightProducer.ServerStreamListener

Modifier and Type	Method	Description
default void	FlightSqlProducer.getStream(FlightProducer.CallContext context, Ticket ticket, FlightProducer.ServerStreamListener listener)	Depending on the provided command, method either: 1.
void	FlightSqlProducer.getStreamCatalogs(FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for catalogs based data stream.
void	NoOpFlightSqlProducer.getStreamCatalogs(FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamCrossReference(FlightSql.CommandGetCrossReference command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for cross reference based data stream.
void	NoOpFlightSqlProducer.getStreamCrossReference(FlightSql.CommandGetCrossReference command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamExportedKeys(FlightSql.CommandGetExportedKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for foreign keys based data stream.
void	NoOpFlightSqlProducer.getStreamExportedKeys(FlightSql.CommandGetExportedKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamImportedKeys(FlightSql.CommandGetImportedKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for foreign keys based data stream.
void	NoOpFlightSqlProducer.getStreamImportedKeys(FlightSql.CommandGetImportedKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for a particular prepared statement query instance.
void	NoOpFlightSqlProducer.getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for primary keys based data stream.
void	NoOpFlightSqlProducer.getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamSchemas(FlightSql.CommandGetDbSchemas command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for schemas based data stream.
void	NoOpFlightSqlProducer.getStreamSchemas(FlightSql.CommandGetDbSchemas command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamSqlInfo(FlightSql.CommandGetSqlInfo command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for SQL info based data stream.
void	NoOpFlightSqlProducer.getStreamSqlInfo(FlightSql.CommandGetSqlInfo command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamStatement(FlightSql.TicketStatementQuery ticket, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for a SQL query based data stream.
void	NoOpFlightSqlProducer.getStreamStatement(FlightSql.TicketStatementQuery ticket, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamTables(FlightSql.CommandGetTables command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for tables based data stream.
void	NoOpFlightSqlProducer.getStreamTables(FlightSql.CommandGetTables command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamTableTypes(FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for table types based data stream.
void	NoOpFlightSqlProducer.getStreamTableTypes(FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	FlightSqlProducer.getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)	Returns data for type info based data stream.
void	NoOpFlightSqlProducer.getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener)
void	SqlInfoBuilder.send(List<Integer> infos, FlightProducer.ServerStreamListener listener)	Send the requested information to given ServerStreamListener.