Package io.deephaven.pivot
Class PivotTableViewSubscription
- All Implemented Interfaces:
LogOutputAppendable
,LivenessManager
,LivenessNode
,LivenessReferent
,Serializable
Tool that manages an active subscription to a
PivotTableView
.- See Also:
-
Nested Class Summary
Nested Classes -
Constructor Summary
ConstructorsConstructorDescriptionPivotTableViewSubscription
(@NotNull Scheduler scheduler, SessionService.ErrorTransformer errorTransformer, BarrageMessageWriter.Factory streamGeneratorFactory, @NotNull PivotTableView view, @NotNull io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener, @NotNull BarrageSubscriptionOptions subscriptionOptions, long intervalDurationMillis) -
Method Summary
Modifier and TypeMethodDescriptionvoid
protected void
destroy()
void
setViewport
(@Nullable RowSet viewportColumns, @Nullable RowSet viewportRows, boolean reverseViewport) Methods inherited from class io.deephaven.engine.liveness.LivenessArtifact
manageWithCurrentScope
Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode
getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage
Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent
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
-
PivotTableViewSubscription
public PivotTableViewSubscription(@NotNull @NotNull Scheduler scheduler, @NotNull SessionService.ErrorTransformer errorTransformer, @NotNull BarrageMessageWriter.Factory streamGeneratorFactory, @NotNull @NotNull PivotTableView view, @NotNull @NotNull io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener, @NotNull @NotNull BarrageSubscriptionOptions subscriptionOptions, long intervalDurationMillis)
-
-
Method Details
-
destroy
@OverridingMethodsMustInvokeSuper protected void destroy()- Overrides:
destroy
in classReferenceCountedLivenessReferent
-
completed
public void completed() -
setViewport
-