Package io.deephaven.engine.table.impl

Interface NotificationStepReceiver

All Known Implementing Classes:
AppendOnlyArrayBackedInputTable, BarrageBlinkTable, BarrageMessageProducer, BarrageRedirectedTable, BarrageTable, BaseTable, DeferredViewTable, IcebergTableImpl, InMemoryTable, KeyedArrayBackedInputTable, PartitionAwareSourceTable, QueryReplayGroupedTable, QueryTable, QueryTable.FilteredTable, RedefinableTable, ReplayGroupedFullTable, ReplayLastByGroupedTable, ReplayTable, ReplayTableBase, SimpleSourceTable, SourceTable, TimeTable, UncoalescedTable, UpdatableTable, UpdateSourceQueryTable
public interface NotificationStepReceiver
Used by OperationSnapshotControl to set the notification step of elements in our DAG.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final long
    NULL_NOTIFICATION_STEP
    The null value for recorded notification steps.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    initializeLastNotificationStep(@NotNull LogicalClock clock)
    Deliver the appropriate last notification step to a receiver that isn't derived from a NotificationStepSource.
    void
    setLastNotificationStep(long lastNotificationStep)
    Deliver a last notification step to this receiver.

  • Field Details

    • NULL_NOTIFICATION_STEP

      static final long NULL_NOTIFICATION_STEP
      The null value for recorded notification steps.
      See Also:

  • Method Details

    • setLastNotificationStep

      void setLastNotificationStep(long lastNotificationStep)
      Deliver a last notification step to this receiver.
      Parameters:
      lastNotificationStep - The last notification step to be delivered

    • initializeLastNotificationStep

      @FinalDefault default void initializeLastNotificationStep(@NotNull @NotNull LogicalClock clock)
      Deliver the appropriate last notification step to a receiver that isn't derived from a NotificationStepSource.