Package io.deephaven.extensions.barrage

Class BarrageMessageWriterImpl.Factory

java.lang.Object

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.Factory

All Implemented Interfaces:

BarrageMessageWriter.Factory

Direct Known Subclasses:

BarrageMessageWriterImpl.ArrowFactory

Enclosing class:

BarrageMessageWriterImpl

public static class BarrageMessageWriterImpl.Factory
extends Object
implements BarrageMessageWriter.Factory

Constructor Summary

Constructors

Constructor	Description
Factory()

Method Summary

Modifier and Type	Method	Description
BarrageMessageWriter.MessageView	getSchemaView(@NotNull ToIntFunction<com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)	Create a BarrageMessageWriter.MessageView of the Schema to send as the initial message to a new subscriber.
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 java.lang.Object

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

Constructor Details

Factory

public Factory()

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

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

getSchemaView

public BarrageMessageWriter.MessageView getSchemaView(@NotNull
 @NotNull ToIntFunction<com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)

Description copied from interface: BarrageMessageWriter.Factory

Create a BarrageMessageWriter.MessageView of the Schema to send as the initial message to a new subscriber.

Specified by:

getSchemaView in interface BarrageMessageWriter.Factory

Parameters:

schemaPayloadWriter - a function that writes schema data to a FlatBufferBuilder and returns the schema offset

Returns:

a MessageView that can be sent to a subscriber