Package io.deephaven.server.arrow
package io.deephaven.server.arrow
-
ClassDescriptionHelper class that maintains a subscription whether it was created by a bi-directional stream request or the no-client-streaming request.Interface for the individual handlers for the DoExchange.This is a stateful observer; a DoPut stream begins with its schema.Provides utility methods to extract viewport, column and other information from Barrage Subscription and Snapshot requests.Handler for DoGetRequest over DoExchange.Factory to handle Barrage DoExchange snapshot requests.Handler for BarrageSubscriptionRequest over DoExchange.Factory to handle Barrage DoExchange subscription requests.The ExchangeMarshaller is a pluggable component within
ArrowFlightUtilthat translated exported objects into suitable Barrage messages.The return value from aExchangeMarshaller.subscribe(BarrageSubscriptionRequest, BarrageSubscriptionOptions, Object, StreamObserver)call.A dagger module that providesexchange marshallersandhandlersfor use by theArrowFlightUtilDoExchangeMarshaller, loaded using aServiceLoaderconstructed with the injectedScheduler,SessionService.ErrorTransformerandBarrageMessageWriter.Factoryparameters.To add an additionalExchangeMarshaller, implement this Factory and add it as a service.The ExchangeRequestHandlerFactory is a pluggable component withinArrowFlightUtilthat provides ahandlerfor each type of barrage message.An ExchangeMarshaller forHierarchicalTableView.TableExchangeMarshaller the implementation ofExchangeMarshallerfor handling exportedTables, providing both snapshot and subscription capabilities.