Package io.deephaven.server.arrow

Interface ExchangeMarshallerModule.Factory

All Known Implementing Classes:

HierarchicalTableViewExchangeMarshaller.Factory, TableExchangeMarshaller.Factory

Enclosing class:

ExchangeMarshallerModule

public static interface ExchangeMarshallerModule.Factory

To add an additional ExchangeMarshaller, implement this Factory and add it as a service.

Method Summary

Modifier and Type	Method	Description
ExchangeMarshaller	create(Scheduler scheduler, SessionService.ErrorTransformer errorTransformer, BarrageMessageWriter.Factory streamGeneratorFactory, Supplier<JobScheduler> propagationJobSchedulerFactory)	Creates the marshaller.

Method Details

create

ExchangeMarshaller create(Scheduler scheduler,
 SessionService.ErrorTransformer errorTransformer,
 BarrageMessageWriter.Factory streamGeneratorFactory,
 Supplier<JobScheduler> propagationJobSchedulerFactory)

Creates the marshaller. Any BarrageMessageProducer it makes writes each propagation phase to its subscribers on a scheduler from propagationJobSchedulerFactory.