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 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

  • 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