Package io.deephaven.pivot

Class PivotMarshallerModule.PivotSubscriptionRequestHandlerFactory

java.lang.Object

io.deephaven.pivot.PivotMarshallerModule.PivotSubscriptionRequestHandlerFactory

All Implemented Interfaces:

ExchangeRequestHandlerFactory

Enclosing class:

PivotMarshallerModule

@AutoService(io.deephaven.server.arrow.ExchangeRequestHandlerFactory.class)
public static class PivotMarshallerModule.PivotSubscriptionRequestHandlerFactory
extends Object
implements ExchangeRequestHandlerFactory

Factory to handle Barrage DoExchange subscription requests.

Constructor Summary

Constructors

Constructor	Description
PivotSubscriptionRequestHandlerFactory()

Method Summary

Modifier and Type	Method	Description
ArrowFlightUtil.DoExchangeMarshaller.Handler	create(ArrowFlightUtil.DoExchangeMarshaller marshaller, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)
byte	type()

Methods inherited from class java.lang.Object

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

Constructor Details

PivotSubscriptionRequestHandlerFactory

public PivotSubscriptionRequestHandlerFactory()

Method Details

type

public byte type()

Specified by:

type in interface ExchangeRequestHandlerFactory

create

public ArrowFlightUtil.DoExchangeMarshaller.Handler create(ArrowFlightUtil.DoExchangeMarshaller marshaller,
 io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)

Specified by:

create in interface ExchangeRequestHandlerFactory