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.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MIN_UPDATE_INTERVAL_MS

Constructor Summary

Constructors

Constructor	Description
ArrowFlightUtil()

Method Summary

Modifier and Type	Method	Description
static void	DoGetCustom(BarrageStreamGenerator.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

Field Details

DEFAULT_MIN_UPDATE_INTERVAL_MS

public static final int DEFAULT_MIN_UPDATE_INTERVAL_MS

Constructor Details

ArrowFlightUtil

public ArrowFlightUtil()

Method Details

DoGetCustom

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