Package io.deephaven.extensions.barrage

Class BarrageStreamGeneratorImpl.ArrowFactory

java.lang.Object

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.Factory

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.ArrowFactory

All Implemented Interfaces:

BarrageStreamGenerator.Factory

Enclosing class:

BarrageStreamGeneratorImpl

public static class BarrageStreamGeneratorImpl.ArrowFactory
extends BarrageStreamGeneratorImpl.Factory

This factory writes data in Arrow's IPC format which has a terse header and no room for metadata.

Constructor Summary

Constructors

Constructor	Description
ArrowFactory()

Method Summary

Modifier and Type	Method	Description
BarrageStreamGenerator	newGenerator(BarrageMessage message, BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)	Create a StreamGenerator that now owns the BarrageMessage.

Methods inherited from class io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.Factory

getSchemaView

Methods inherited from class java.lang.Object

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

Constructor Details

ArrowFactory

public ArrowFactory()

Method Details

newGenerator

public BarrageStreamGenerator newGenerator(BarrageMessage message,
 BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)

Description copied from interface: BarrageStreamGenerator.Factory

Create a StreamGenerator that now owns the BarrageMessage.

Specified by:

newGenerator in interface BarrageStreamGenerator.Factory

Overrides:

newGenerator in class BarrageStreamGeneratorImpl.Factory

Parameters:

message - the message that contains the update that we would like to propagate

metricsConsumer - a method that can be used to record write metrics