Package io.deephaven.extensions.barrage

Class BarrageStreamGeneratorImpl.Factory

java.lang.Object

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.Factory

All Implemented Interfaces:

BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View>

Direct Known Subclasses:

BarrageStreamGeneratorImpl.ArrowFactory

Enclosing class:

BarrageStreamGeneratorImpl

public static class BarrageStreamGeneratorImpl.Factory
extends Object
implements BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View>

Constructor Summary

Constructors

Constructor	Description
Factory()

Method Summary

Modifier and Type	Method	Description
BarrageStreamGeneratorImpl.View	getSchemaView(@NotNull ToIntFunction<com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)	Create a MessageView of the Schema to send as the initial message to a new subscriber.
BarrageStreamGenerator<BarrageStreamGeneratorImpl.View>	newGenerator(BarrageMessage message, BarragePerformanceLog.WriteMetricsConsumer metricsConsumer)	Create a StreamGenerator 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

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>

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 BarrageStreamGeneratorImpl.View getSchemaView(@NotNull
 @NotNull ToIntFunction<com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)

Description copied from interface: BarrageStreamGenerator.Factory

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

Specified by:

getSchemaView in interface BarrageStreamGenerator.Factory<BarrageStreamGeneratorImpl.View>

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