Package io.deephaven.engine.liveness

Interface LivenessManager

All Known Subinterfaces:
DelegatingLivenessNode, LazySnapshotTable, LivenessNode, PartitionedTable, QueryScope, ReleasableLivenessManager, ScriptSession, ShiftObliviousListener, Table, TableAdapter, TableDefaults, TableListener, TableUpdateListener
All Known Implementing Classes:
AbstractScriptSession, AbstractScriptSession.ScriptSessionQueryScope, AppendOnlyArrayBackedInputTable, AppendOnlyAssertionInstrumentedListenerAdapter, ArrowFlightUtil.DoExchangeMarshaller, AutoTuningIncrementalReleaseFilter, BarrageBlinkTable, BarrageMessageProducer, BarrageRedirectedTable, BarrageSnapshotImpl, BarrageSubscriptionImpl, BarrageTable, BaseGridAttributes, BaseIncrementalReleaseFilter, BaseTable, BaseTable.ListenerImpl, BaseTable.ShiftObliviousListenerImpl, BucketedChunkedAjMergedListener, ClockFilter, ComposedFilter, ConjunctiveFilter, DeferredViewTable, DeferredViewTable.SimpleTableReference, DeferredViewTable.TableReference, DelegatingScriptSession, DisjunctiveFilter, DynamicWhereFilter, EmptyQueryScope, FigureWidget, GroovyDeephavenSession, HierarchicalTableView, HierarchicalTableViewSubscription, IncrementalReleaseFilter, InitialSnapshotTable, InMemoryTable, InstrumentedTableListenerBase, InstrumentedTableUpdateListener, InstrumentedTableUpdateListenerAdapter, JoinListenerRecorder, KafkaStreamPublisher, KeyedArrayBackedInputTable, ListenerRecorder, LiveAttributeMap, LivenessArtifact, LivenessScope, MergedListener, NoLanguageDeephavenSession, PartitionAwareSourceTable, PartitionedTableImpl, PermanentLivenessManager, PoisonedQueryScope, PrintListener, PublishToKafka, PythonDeephavenSession, PythonListenerAdapter, PythonReplayListenerAdapter, PythonReplayShiftObliviousListenerAdapter, PythonShiftObliviousListenerAdapter, QueryReplayGroupedTable, QueryTable, QueryTable.FilteredTable, RedefinableTable, ReferenceCountedLivenessNode, ReplayGroupedFullTable, ReplayLastByGroupedTable, ReplayTable, ReplayTableBase, RollingReleaseFilter, RollupTableImpl, SessionState.ExportObject, ShiftObliviousInstrumentedListener, ShiftObliviousInstrumentedListenerAdapter, SimpleSourceTable, SingletonLivenessManager, SnapshotIncrementalListener, SnapshotInternalListener, SortedAssertionInstrumentedListenerAdapter, SortedClockFilter, SortListener, SourcePartitionedTable, SourceTable, SourceTable.QueryTableReference, StandaloneQueryScope, StreamPublisherBase, TableSupplier, TimeSeriesFilter, TimeTable, ToMapListener, TreeTableImpl, UncoalescedTable, UnsortedClockFilter, UpdatableTable, UpdateSourceCombiner, UpdateSourceQueryTable, WhereFilterLivenessArtifactImpl, ZeroKeyChunkedAjMergedListener
public interface LivenessManager
Interface for objects that retainReference LivenessReferents until such time as they are no longer necessary.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    manage(@NotNull LivenessReferent referent)
    Add the specified referent to this manager.
    boolean
    tryManage(@NotNull LivenessReferent referent)
    Attempt to add referent to this manager.

  • Method Details

    • manage

      @FinalDefault default void manage(@NotNull @NotNull LivenessReferent referent)
      Add the specified referent to this manager. referent must be live. If this manager is also a LivenessReferent, then it must also be live.
      Parameters:
      referent - The referent to add

    • tryManage

      boolean tryManage(@NotNull @NotNull LivenessReferent referent)
      Attempt to add referent to this manager. Will succeed if referent is live and if this manager is not a LivenessReferent or is live.
      Parameters:
      referent - The referent to add
      Returns:
      Whether the referent was in fact added