Interface HasRefreshingSource

All Known Implementing Classes:
BarrageBlinkTable, BarrageRedirectedTable, BarrageTable, IcebergTableImpl, PartitionAwareSourceTable, SimpleSourceTable, SourceTable, TimeTable

public interface HasRefreshingSource
An interface to indicate that a source has refreshing behavior and can provide performance entries.

The provided performance entries are used to generate entries in the ancestors log, so that refreshing roots that typically do not have a BaseTable.ListenerImpl or MergedListener can participate in ancestor discovery.

  • Method Details

    • sourceEntries

      @NotNull @NotNull Stream<PerformanceEntry> sourceEntries()
      Return a stream of performance entries that represent the InstrumentedTableUpdateSource which drive this table.

      If no such sources, exist, then an empty stream is returned.

      Returns:
      a stream of performance entries for this node in the graph