Package io.deephaven.extensions.barrage

Class BarrageMessageWriterImpl.ArrowFactory

java.lang.Object

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.Factory

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.ArrowFactory

All Implemented Interfaces:

BarrageMessageWriter.Factory

Enclosing class:

BarrageMessageWriterImpl

public static class BarrageMessageWriterImpl.ArrowFactory
extends BarrageMessageWriterImpl.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
BarrageMessageWriter	newMessageWriter(@NotNull BarrageMessage message, @NotNull ChunkWriter<Chunk<Values>>[] chunkWriters, BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)	Create a BarrageMessageWriter that now owns the BarrageMessage.

Methods inherited from class io.deephaven.extensions.barrage.BarrageMessageWriterImpl.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

newMessageWriter

public BarrageMessageWriter newMessageWriter(@NotNull
 @NotNull BarrageMessage message,
 @NotNull
 @NotNull ChunkWriter<Chunk<Values>>[] chunkWriters,
 @NotNull
 BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)

Description copied from interface: BarrageMessageWriter.Factory

Create a BarrageMessageWriter that now owns the BarrageMessage.

Specified by:

newMessageWriter in interface BarrageMessageWriter.Factory

Overrides:

newMessageWriter in class BarrageMessageWriterImpl.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