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, org.apache.arrow.flight.impl.Flight.FlightDescriptor flightDescriptor)	Create a BarrageMessageWriter.MessageView of the Schema to send as the initial message, with a flight descriptor for the table.
BarrageMessageWriter	newMessageWriter(@NotNull BarrageMessage message, @NotNull ChunkWriter<Chunk<Values>>[] chunkWriters, BarrageMessageWriter.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

Methods inherited from interface io.deephaven.extensions.barrage.BarrageMessageWriter.Factory

getSchemaView

Constructor Details

Factory

public Factory()

Method Details

newMessageWriter

public BarrageMessageWriter newMessageWriter(@NotNull
 @NotNull BarrageMessage message,
 @NotNull
 @NotNull ChunkWriter<Chunk<Values>>[] chunkWriters,
 @NotNull
 BarrageMessageWriter.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,
 org.apache.arrow.flight.impl.Flight.FlightDescriptor flightDescriptor)

Description copied from interface: BarrageMessageWriter.Factory

Create a BarrageMessageWriter.MessageView of the Schema to send as the initial message, with a flight descriptor for the table.

Specified by:

getSchemaView in interface BarrageMessageWriter.Factory

Parameters:

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

flightDescriptor - the flight descriptor for the table, null if it need not be set

Returns:

a MessageView that can be sent to a subscriber