Package io.deephaven.server.arrow

Class ArrowFlightUtil.DoExchangeMarshaller

java.lang.Object

io.deephaven.engine.liveness.SingletonLivenessManager

io.deephaven.server.arrow.ArrowFlightUtil.DoExchangeMarshaller

All Implemented Interfaces:

LivenessManager, ReleasableLivenessManager, io.grpc.stub.StreamObserver<InputStream>, Closeable, AutoCloseable

Enclosing class:

ArrowFlightUtil

public static class ArrowFlightUtil.DoExchangeMarshaller
extends SingletonLivenessManager
implements io.grpc.stub.StreamObserver<InputStream>, Closeable

Helper class that maintains a subscription whether it was created by a bi-directional stream request or the no-client-streaming request. If the SubscriptionRequest sets the sequence, then it treats sequence as a watermark and will not send out-of-order requests (due to out-of-band requests). The client should already anticipate subscription changes may be coalesced by the BarrageMessageProducer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ArrowFlightUtil.DoExchangeMarshaller.Factory

Constructor Summary

Constructors

Constructor

Description

DoExchangeMarshaller(TicketRouter ticketRouter, BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View> streamGeneratorFactory, BarrageMessageProducer.Operation.Factory<BarrageStreamGeneratorImpl.View> bmpOperationFactory, HierarchicalTableViewSubscription.Factory htvsFactory, BarrageMessageProducer.Adapter<io.grpc.stub.StreamObserver<InputStream>,io.grpc.stub.StreamObserver<BarrageStreamGeneratorImpl.View>> listenerAdapter, BarrageMessageProducer.Adapter<io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest,BarrageSubscriptionOptions> subscriptionOptAdapter, BarrageMessageProducer.Adapter<io.deephaven.barrage.flatbuf.BarrageSnapshotRequest,BarrageSnapshotOptions> snapshotOptAdapter, SessionService.ErrorTransformer errorTransformer, SessionState session, io.grpc.stub.StreamObserver<InputStream> responseObserver)

Method Summary

Modifier and Type	Method	Description
void	close()
void	onCancel()
void	onCompleted()
void	onError(Throwable t)
void	onNext(InputStream request)

Methods inherited from class io.deephaven.engine.liveness.SingletonLivenessManager

release, tryManage

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.liveness.LivenessManager

manage

Constructor Details

DoExchangeMarshaller

@AssistedInject
public DoExchangeMarshaller(TicketRouter ticketRouter,
 BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View> streamGeneratorFactory,
 BarrageMessageProducer.Operation.Factory<BarrageStreamGeneratorImpl.View> bmpOperationFactory,
 HierarchicalTableViewSubscription.Factory htvsFactory,
 BarrageMessageProducer.Adapter<io.grpc.stub.StreamObserver<InputStream>,io.grpc.stub.StreamObserver<BarrageStreamGeneratorImpl.View>> listenerAdapter,
 BarrageMessageProducer.Adapter<io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest,BarrageSubscriptionOptions> subscriptionOptAdapter,
 BarrageMessageProducer.Adapter<io.deephaven.barrage.flatbuf.BarrageSnapshotRequest,BarrageSnapshotOptions> snapshotOptAdapter,
 SessionService.ErrorTransformer errorTransformer,
 @Assisted
 SessionState session,
 @Assisted
 io.grpc.stub.StreamObserver<InputStream> responseObserver)

Method Details

onNext

public void onNext(InputStream request)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<InputStream>

onCancel

public void onCancel()

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<InputStream>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<InputStream>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable