Class BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractBlockingStub<BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub>
io.deephaven.flightjs.protocol.BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub
Enclosing class:
BrowserFlightServiceGrpc

public static final class BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub>
 A flight js service is a (non-proper) extension of arrow flight service
 that augments existing client-streaming (or bidirectional streaming) methods
 with a pair that can be used to simulate a client stream over unary requests.
 
  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>
  • Method Summary

    Modifier and Type Method Description
    protected BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub build​(io.grpc.Channel channel, io.grpc.CallOptions callOptions)  
    BrowserFlight.BrowserNextResponse nextDoExchange​(org.apache.arrow.flight.impl.Flight.FlightData request)  
    BrowserFlight.BrowserNextResponse nextDoPut​(org.apache.arrow.flight.impl.Flight.FlightData request)  
    BrowserFlight.BrowserNextResponse nextHandshake​(org.apache.arrow.flight.impl.Flight.HandshakeRequest request)  
    Iterator<org.apache.arrow.flight.impl.Flight.FlightData> openDoExchange​(org.apache.arrow.flight.impl.Flight.FlightData request)
    Open a bidirectional data channel for a given descriptor.
    Iterator<org.apache.arrow.flight.impl.Flight.PutResult> openDoPut​(org.apache.arrow.flight.impl.Flight.FlightData request)
    Push a stream to the flight service associated with a particular flight stream.
    Iterator<org.apache.arrow.flight.impl.Flight.HandshakeResponse> openHandshake​(org.apache.arrow.flight.impl.Flight.HandshakeRequest request)
    Handshake between client and server.

    Methods inherited from class io.grpc.stub.AbstractBlockingStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Method Details

    • build

      protected BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub build​(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<BrowserFlightServiceGrpc.BrowserFlightServiceBlockingStub>
    • openHandshake

      public Iterator<org.apache.arrow.flight.impl.Flight.HandshakeResponse> openHandshake​(org.apache.arrow.flight.impl.Flight.HandshakeRequest request)
       Handshake between client and server. Depending on the server, the
       handshake may be required to determine the token that should be used for
       future operations. Both request and response are streams to allow multiple
       round-trips depending on auth mechanism.
       
    • nextHandshake

      public BrowserFlight.BrowserNextResponse nextHandshake​(org.apache.arrow.flight.impl.Flight.HandshakeRequest request)
    • openDoPut

      public Iterator<org.apache.arrow.flight.impl.Flight.PutResult> openDoPut​(org.apache.arrow.flight.impl.Flight.FlightData request)
       Push a stream to the flight service associated with a particular
       flight stream. This allows a client of a flight service to upload a stream
       of data. Depending on the particular flight service, a client consumer
       could be allowed to upload a single stream per descriptor or an unlimited
       number. In the latter, the service might implement a 'seal' action that
       can be applied to a descriptor once all streams are uploaded.
       
    • nextDoPut

      public BrowserFlight.BrowserNextResponse nextDoPut​(org.apache.arrow.flight.impl.Flight.FlightData request)
    • openDoExchange

      public Iterator<org.apache.arrow.flight.impl.Flight.FlightData> openDoExchange​(org.apache.arrow.flight.impl.Flight.FlightData request)
       Open a bidirectional data channel for a given descriptor. This
       allows clients to send and receive arbitrary Arrow data and
       application-specific metadata in a single logical stream. In
       contrast to DoGet/DoPut, this is more suited for clients
       offloading computation (rather than storage) to a Flight service.
       
    • nextDoExchange

      public BrowserFlight.BrowserNextResponse nextDoExchange​(org.apache.arrow.flight.impl.Flight.FlightData request)