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
-
Field Summary
Fields inherited from class io.deephaven.kafka.StreamPublisherBase
chunks, consumer -
Constructor Summary
ConstructorsConstructorDescriptionProtoMessageTablePublisher(Descriptors.Descriptor descriptor, TableDefinition tableDefinition, ProtoMessageTableContext.KeyOrValueProcessorImpl processor, Runnable shutdownHook, boolean extraLongColumn) -
Method Summary
Methods inherited from class io.deephaven.kafka.StreamPublisherBase
getChunksToFill, registerMethods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode
getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanageMethods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent
destroy, dropReference, tryRetainReferenceMethods inherited from class io.deephaven.util.referencecounting.ReferenceCounted
append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCountMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface io.deephaven.engine.liveness.LivenessManager
manage, unmanage, unmanageMethods 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
-
add
-
flush
public void flush()- Specified by:
flushin interfaceStreamPublisher- Overrides:
flushin classStreamPublisherBase
-
descriptor
-