Package io.deephaven.engine.table.impl

Interface ColumnSourceManager

All Known Implementing Classes:
RegionedColumnSourceManager
public interface ColumnSourceManager
Manager for ColumnSources in a Table.

  • Method Details

    • getColumnSources

      Map<String,? extends DeferredGroupingColumnSource<?>> getColumnSources()
      Get a map of name to DeferredGroupingColumnSource for the column sources maintained by this manager.
      Returns:
      An unmodifiable view of the column source map maintained by this manager.

    • disableGrouping

      void disableGrouping()
      Turn off column grouping, and clear the groupings on all GROUPING column sources. Note that this does *not* affect PARTITIONING columns.

    • addLocation

      void addLocation(@NotNull @NotNull TableLocation tableLocation)
      Add a table location to the list to be checked in run().
      Parameters:
      tableLocation - The table location to be added

    • refresh

      WritableRowSet refresh()
      Observe size changes in the previously added table locations, and update the managed column sources accordingly.
      Returns:
      The RowSet of added keys

    • allLocations

      Collection<TableLocation> allLocations()
      Get the added locations, first the ones that have been "included" (found to exist with non-zero size) in order of inclusion, then the remainder in order of discovery.
      Returns:
      All known locations, ordered as described

    • includedLocations

      Collection<TableLocation> includedLocations()
      Get the added locations that have been found to exist and have non-zero size.
      Returns:
      The added locations that have been found to exist and have non-zero size

    • isEmpty

      boolean isEmpty()
      Report whether this ColumnSourceManager has no locations that have been "included" (i.e. found to exist with non-zero size).
      Returns:
      True if there are no included locations

    • removeLocationKey

      boolean removeLocationKey(@NotNull @NotNull ImmutableTableLocationKey tableLocationKey)
      Remove a table location key from the sources.
      Parameters:
      tableLocationKey - the location key being removed
      Returns:
      true if the location key was actually removed