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<BarrageStreamGeneratorImpl.View>

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<BarrageStreamGeneratorImpl.View>	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<BarrageStreamGeneratorImpl.View> 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<BarrageStreamGeneratorImpl.View>

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