Class RegionedColumnSourceManager
java.lang.Object
io.deephaven.engine.table.impl.sources.regioned.RegionedColumnSourceManager
- All Implemented Interfaces:
ColumnSourceManager
Manage column sources made up of regions in their own row key address space.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
addLocation
(@NotNull TableLocation tableLocation) Add a table location to the list to be checked in run().final Collection<TableLocation>
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.final void
Turn off column grouping, and clear the groupings on all GROUPING column sources.final Map<String,
? extends DeferredGroupingColumnSource<?>> Get a map of name toDeferredGroupingColumnSource
for the column sources maintained by this manager.final Collection<TableLocation>
Get the added locations that have been found to exist and have non-zero size.final boolean
isEmpty()
Report whether this ColumnSourceManager has no locations that have been "included" (i.e.refresh()
Observe size changes in the previously added table locations, and update the managed column sources accordingly.boolean
removeLocationKey
(@NotNull ImmutableTableLocationKey locationKey) Remove a table location key from the sources.
-
Method Details
-
addLocation
Description copied from interface:ColumnSourceManager
Add a table location to the list to be checked in run().- Specified by:
addLocation
in interfaceColumnSourceManager
- Parameters:
tableLocation
- The table location to be added
-
removeLocationKey
Description copied from interface:ColumnSourceManager
Remove a table location key from the sources.- Specified by:
removeLocationKey
in interfaceColumnSourceManager
- Parameters:
locationKey
- the location key being removed- Returns:
- true if the location key was actually removed
-
refresh
Description copied from interface:ColumnSourceManager
Observe size changes in the previously added table locations, and update the managed column sources accordingly.- Specified by:
refresh
in interfaceColumnSourceManager
- Returns:
- The RowSet of added keys
-
allLocations
Description copied from interface:ColumnSourceManager
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.- Specified by:
allLocations
in interfaceColumnSourceManager
- Returns:
- All known locations, ordered as described
-
includedLocations
Description copied from interface:ColumnSourceManager
Get the added locations that have been found to exist and have non-zero size.- Specified by:
includedLocations
in interfaceColumnSourceManager
- Returns:
- The added locations that have been found to exist and have non-zero size
-
isEmpty
public final boolean isEmpty()Description copied from interface:ColumnSourceManager
Report whether this ColumnSourceManager has no locations that have been "included" (i.e. found to exist with non-zero size).- Specified by:
isEmpty
in interfaceColumnSourceManager
- Returns:
- True if there are no included locations
-
getColumnSources
Description copied from interface:ColumnSourceManager
Get a map of name toDeferredGroupingColumnSource
for the column sources maintained by this manager.- Specified by:
getColumnSources
in interfaceColumnSourceManager
- Returns:
- An unmodifiable view of the column source map maintained by this manager.
-
disableGrouping
public final void disableGrouping()Description copied from interface:ColumnSourceManager
Turn off column grouping, and clear the groupings on all GROUPING column sources. Note that this does *not* affect PARTITIONING columns.- Specified by:
disableGrouping
in interfaceColumnSourceManager
-