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 TypeMethodDescriptionvoidprotected voiddestroy()voidsetViewport(@Nullable RowSet viewportColumns, @Nullable RowSet viewportRows, boolean reverseViewport) Methods inherited from class io.deephaven.engine.liveness.LivenessArtifact
manageWithCurrentScopeMethods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode
getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanageMethods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent
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
-
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:
destroyin classReferenceCountedLivenessReferent
-
completed
public void completed() -
setViewport
-