Package io.deephaven.enterprise.webclientdata2

Class ProtoMessageTablePublisher<T extends Message>

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<T>

All Implemented Interfaces:

LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, StreamPublisher

public class ProtoMessageTablePublisher<T extends Message>
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<T> processor, Runnable shutdownHook, boolean extraLongColumn)

Method Summary

Modifier and Type	Method	Description
void	add(T msg)
void	add(T 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

ensureCleanupOnGC, findAnyManagedReferent, forEachManagedReference, 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<T> processor,
 Runnable shutdownHook,
 boolean extraLongColumn)

Method Details

shutdown

public void shutdown()

add

public void add(T msg)

add

public void add(T msg,
 long extra)

flush

public void flush()

Specified by:

flush in interface StreamPublisher

Overrides:

flush in class StreamPublisherBase

descriptor

public Descriptors.Descriptor descriptor()