Package io.deephaven.enterprise.webclientdata2

Class ProtoMessageTablePublisher

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

io.deephaven.engine.liveness.ReferenceCountedLivenessNode

io.deephaven.kafka.StreamPublisherBase

io.deephaven.enterprise.webclientdata2.ProtoMessageTablePublisher

All Implemented Interfaces:

LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, StreamPublisher

public class ProtoMessageTablePublisher
extends StreamPublisherBase

Field Summary

Fields inherited from class io.deephaven.kafka.StreamPublisherBase

chunks, consumer

Constructor Summary

Constructors

Constructor	Description
ProtoMessageTablePublisher(Descriptors.Descriptor descriptor, TableDefinition tableDefinition, ProtoMessageTableContext.KeyOrValueProcessorImpl processor, Runnable shutdownHook, boolean extraLongColumn)

Method Summary

Modifier and Type	Method	Description
void	add(Message msg)
void	add(Message msg, long extra)
Descriptors.Descriptor	descriptor()
void	flush()
void	shutdown()

Methods inherited from class io.deephaven.kafka.StreamPublisherBase

getChunksToFill, register

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode

getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

destroy, dropReference, tryRetainReference

Methods inherited from class io.deephaven.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.liveness.LivenessManager

manage, unmanage, unmanage

Methods inherited from interface io.deephaven.engine.liveness.LivenessReferent

dropReference, getReferentDescription, retainReference, tryRetainReference

Constructor Details

ProtoMessageTablePublisher

public ProtoMessageTablePublisher(Descriptors.Descriptor descriptor,
 TableDefinition tableDefinition,
 ProtoMessageTableContext.KeyOrValueProcessorImpl processor,
 Runnable shutdownHook,
 boolean extraLongColumn)

Method Details

shutdown

public void shutdown()

add

public void add(Message msg)

add

public void add(Message msg,
 long extra)

flush

public void flush()

Specified by:

flush in interface StreamPublisher

Overrides:

flush in class StreamPublisherBase

descriptor

public Descriptors.Descriptor descriptor()