Package io.deephaven.server.arrow

Class FlightServiceGrpcImpl

java.lang.Object

org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase

io.deephaven.server.arrow.FlightServiceGrpcImpl

All Implemented Interfaces:

io.grpc.BindableService, org.apache.arrow.flight.impl.FlightServiceGrpc.AsyncService

@Singleton
public class FlightServiceGrpcImpl
extends org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase

Constructor Summary

Constructors

Constructor	Description
FlightServiceGrpcImpl(@Nullable ScheduledExecutorService executorService, BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View> streamGeneratorFactory, SessionService sessionService, SessionService.ErrorTransformer errorTransformer, TicketRouter ticketRouter, ArrowFlightUtil.DoExchangeMarshaller.Factory doExchangeFactory, Map<String,AuthenticationRequestHandler> authRequestHandlers)

Method Summary

Modifier and Type	Method	Description
io.grpc.stub.StreamObserver<InputStream>	doExchangeCustom(io.grpc.stub.StreamObserver<InputStream> responseObserver)	Establish a new DoExchange bi-directional stream.
void	doGetCustom(org.apache.arrow.flight.impl.Flight.Ticket request, io.grpc.stub.StreamObserver<InputStream> responseObserver)
io.grpc.stub.StreamObserver<InputStream>	doPutCustom(io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.PutResult> responseObserver)	Establish a new DoPut bi-directional stream.
void	getFlightInfo(org.apache.arrow.flight.impl.Flight.FlightDescriptor request, @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.FlightInfo> responseObserver)
void	getSchema(org.apache.arrow.flight.impl.Flight.FlightDescriptor request, @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.SchemaResult> responseObserver)
io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.HandshakeRequest>	handshake(@NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.HandshakeResponse> responseObserver)
void	listFlights(org.apache.arrow.flight.impl.Flight.Criteria request, @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.FlightInfo> responseObserver)

Methods inherited from class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase

bindService

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.impl.FlightServiceGrpc.AsyncService

doAction, doExchange, doGet, doPut, listActions

Constructor Details

FlightServiceGrpcImpl

@Inject
public FlightServiceGrpcImpl(@Nullable
 @Nullable ScheduledExecutorService executorService,
 BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View> streamGeneratorFactory,
 SessionService sessionService,
 SessionService.ErrorTransformer errorTransformer,
 TicketRouter ticketRouter,
 ArrowFlightUtil.DoExchangeMarshaller.Factory doExchangeFactory,
 Map<String,AuthenticationRequestHandler> authRequestHandlers)

Method Details

handshake

public io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.HandshakeRequest> handshake(@NotNull
 @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.HandshakeResponse> responseObserver)

listFlights

public void listFlights(@NotNull
 org.apache.arrow.flight.impl.Flight.Criteria request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.FlightInfo> responseObserver)

getFlightInfo

public void getFlightInfo(@NotNull
 org.apache.arrow.flight.impl.Flight.FlightDescriptor request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.FlightInfo> responseObserver)

getSchema

public void getSchema(@NotNull
 org.apache.arrow.flight.impl.Flight.FlightDescriptor request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.SchemaResult> responseObserver)

doGetCustom

public void doGetCustom(org.apache.arrow.flight.impl.Flight.Ticket request,
 io.grpc.stub.StreamObserver<InputStream> responseObserver)

doPutCustom

public io.grpc.stub.StreamObserver<InputStream> doPutCustom(io.grpc.stub.StreamObserver<org.apache.arrow.flight.impl.Flight.PutResult> responseObserver)

Establish a new DoPut bi-directional stream.

Parameters:

responseObserver - the observer to reply to

Returns:

the observer that grpc can delegate received messages to

doExchangeCustom

public io.grpc.stub.StreamObserver<InputStream> doExchangeCustom(io.grpc.stub.StreamObserver<InputStream> responseObserver)

Establish a new DoExchange bi-directional stream.

Parameters:

responseObserver - the observer to reply to

Returns:

the observer that grpc can delegate received messages to