Package io.deephaven.pivot

Class PivotMarshallerModule.PivotSnapshotRequestHandlerFactory

java.lang.Object

io.deephaven.pivot.PivotMarshallerModule.PivotSnapshotRequestHandlerFactory

All Implemented Interfaces:

ExchangeRequestHandlerFactory

Enclosing class:

PivotMarshallerModule

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

Factory to handle Barrage DoExchange snapshot requests.

Constructor Summary

Constructors

Constructor	Description
PivotSnapshotRequestHandlerFactory()

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

PivotSnapshotRequestHandlerFactory

public PivotSnapshotRequestHandlerFactory()

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