Package io.deephaven.extensions.barrage

Interface BarrageMessageWriter.Factory

All Known Implementing Classes:

BarrageMessageWriterImpl.ArrowFactory, BarrageMessageWriterImpl.Factory

Enclosing interface:

BarrageMessageWriter

public static interface BarrageMessageWriter.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.

Method Details

newMessageWriter

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

Create a BarrageMessageWriter that now owns the BarrageMessage.

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

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

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

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