Package io.deephaven.server.arrow

Class BarrageSnapshotRequestHandler.BarrageSnapshotRequestHandlerFactory

java.lang.Object

io.deephaven.server.arrow.BarrageSnapshotRequestHandler.BarrageSnapshotRequestHandlerFactory

All Implemented Interfaces:

ExchangeRequestHandlerFactory

Enclosing class:

BarrageSnapshotRequestHandler

@AutoService(ExchangeRequestHandlerFactory.class)
public static class BarrageSnapshotRequestHandler.BarrageSnapshotRequestHandlerFactory
extends Object
implements ExchangeRequestHandlerFactory

Factory to handle Barrage DoExchange snapshot requests.

Constructor Summary

Constructors

Constructor	Description
BarrageSnapshotRequestHandlerFactory()

Method Summary

Modifier and Type	Method	Description
ArrowFlightUtil.DoExchangeMarshaller.Handler	create(ArrowFlightUtil.DoExchangeMarshaller marshaller, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)	Creates a handler for a DoExchange message.
byte	type()	The type of message that this factory produces a handler for.

Methods inherited from class java.lang.Object

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

Constructor Details

BarrageSnapshotRequestHandlerFactory

public BarrageSnapshotRequestHandlerFactory()

Method Details

type

public byte type()

Description copied from interface: ExchangeRequestHandlerFactory

The type of message that this factory produces a handler for.

Message types are defined in BarrageMessageType.

Specified by:

type in interface ExchangeRequestHandlerFactory

Returns:

the type of message handled by this factory

create

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

Description copied from interface: ExchangeRequestHandlerFactory

Creates a handler for a DoExchange message.

Specified by:

create in interface ExchangeRequestHandlerFactory

Parameters:

marshaller - the DoExchangeMarshaller handling the message

listener - the listener for results of this message

Returns:

the Handler for the message