Package io.deephaven.server.arrow

Class ArrowFlightUtil

java.lang.Object

io.deephaven.server.arrow.ArrowFlightUtil

public class ArrowFlightUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ArrowFlightUtil.DoExchangeMarshaller	Helper class that maintains a subscription whether it was created by a bi-directional stream request or the no-client-streaming request.
static class	ArrowFlightUtil.DoPutObserver	This is a stateful observer; a DoPut stream begins with its schema.

Constructor Summary

Constructors

Constructor	Description
ArrowFlightUtil()

Method Summary

Modifier and Type	Method	Description
static void	DoGetCustom(BarrageMessageWriter.Factory streamGeneratorFactory, SessionState session, TicketRouter ticketRouter, org.apache.arrow.flight.impl.Flight.Ticket request, io.grpc.stub.StreamObserver<InputStream> observer)

Methods inherited from class java.lang.Object

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

Constructor Details

ArrowFlightUtil

public ArrowFlightUtil()

Method Details

DoGetCustom

public static void DoGetCustom(BarrageMessageWriter.Factory streamGeneratorFactory,
 SessionState session,
 TicketRouter ticketRouter,
 org.apache.arrow.flight.impl.Flight.Ticket request,
 io.grpc.stub.StreamObserver<InputStream> observer)