Package io.deephaven.engine.table.impl.sources.regioned

Class RegionedColumnSourceManager

java.lang.Object

io.deephaven.engine.table.impl.sources.regioned.RegionedColumnSourceManager

All Implemented Interfaces:

DelegatingLivenessNode, DelegatingLivenessReferent, LivenessManager, LivenessNode, LivenessReferent, ColumnSourceManager

public class RegionedColumnSourceManager
extends Object
implements ColumnSourceManager, DelegatingLivenessNode

Manage column sources made up of regions in their own row key address space.

Method Summary

Modifier and Type	Method	Description
void	addLocation(@NotNull TableLocation tableLocation)	Add a table location to the list to be checked in run().
final 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.
LivenessNode	asLivenessNode()	Returns the "real" LivenessNode instance.
void	deliverError(@NotNull Throwable error, TableListener.Entry entry)	Advise this ColumnSourceManager that an error has occurred, and that it will no longer be refreshed.
final Map<String,? extends ColumnSource<?>>	getColumnSources()	Get a map of name to ColumnSource for the column sources maintained by this manager.
Map<String,Object>	getTableAttributes(@NotNull TableUpdateMode tableUpdateMode, @NotNull TableUpdateMode tableLocationUpdateMode)	Get a map of Table attributes that can be applied to the output source table, given the update modes of the underlying table location provider.
final Collection<TableLocation>	includedLocations()	Get the added locations that have been found to exist and have non-zero size.
TrackingWritableRowSet	initialize()	Observe initial sizes for the previously added table locations, and update the managed column sources accordingly.
final boolean	isEmpty()	Report whether this ColumnSourceManager has no locations that have been "included" (i.e.
String	locationColumnName()	Get the name of the column that contains the TableLocation values from ColumnSourceManager.locationTable().
Table	locationTable()	Get the added locations that have been found to exist and have non-zero size as a table containing the row sets for each location.
TableUpdate	refresh()	Observe size changes in the previously added table locations, and update the managed column sources accordingly.
void	removeLocationKey(@NotNull ImmutableTableLocationKey locationKey)	Remove a table location key from the sources.
String	rowSetColumnName()	Get the name of the column that contains the RowSet values from ColumnSourceManager.locationTable().

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.deephaven.engine.liveness.DelegatingLivenessNode

asLivenessReferent, tryManage, tryUnmanage, tryUnmanage

Methods inherited from interface io.deephaven.engine.liveness.DelegatingLivenessReferent

dropReference, getWeakReference, tryRetainReference

Methods inherited from interface io.deephaven.engine.liveness.LivenessManager

manage, unmanage, unmanage

Methods inherited from interface io.deephaven.engine.liveness.LivenessReferent

getReferentDescription, retainReference

Method Details

addLocation

public void addLocation(@NotNull
 @NotNull TableLocation tableLocation)

Description copied from interface: ColumnSourceManager

Add a table location to the list to be checked in run().

Specified by:

addLocation in interface ColumnSourceManager

Parameters:

tableLocation - The table location to be added

removeLocationKey

public void removeLocationKey(@NotNull
 @NotNull ImmutableTableLocationKey locationKey)

Description copied from interface: ColumnSourceManager

Remove a table location key from the sources.

Specified by:

removeLocationKey in interface ColumnSourceManager

Parameters:

locationKey - the location key being removed

initialize

public TrackingWritableRowSet initialize()

Description copied from interface: ColumnSourceManager

Observe initial sizes for the previously added table locations, and update the managed column sources accordingly. Create any data indexes that may be derived from the locations.

Specified by:

initialize in interface ColumnSourceManager

Returns:

The initial set of initially-available row keys, to be owned by the caller. This row set will have a data indexer populated with any data indexes that were created.

refresh

public TableUpdate 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 interface ColumnSourceManager

Returns:

The set of added row keys, to be owned by the caller

deliverError

public void deliverError(@NotNull
 @NotNull Throwable error,
 @Nullable
 TableListener.Entry entry)

Description copied from interface: ColumnSourceManager

Advise this ColumnSourceManager that an error has occurred, and that it will no longer be refreshed. This method should ensure that the error is delivered to downstream listeners if appropriate.

Specified by:

deliverError in interface ColumnSourceManager

Parameters:

error - The error that occurred

entry - The failing node's entry, if known

allLocations

public final Collection<TableLocation> 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 interface ColumnSourceManager

Returns:

All known locations, ordered as described

includedLocations

public final Collection<TableLocation> 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 interface ColumnSourceManager

Returns:

The added locations that have been found to exist and have non-zero size

locationTable

public Table locationTable()

Description copied from interface: ColumnSourceManager

Get the added locations that have been found to exist and have non-zero size as a table containing the row sets for each location. May only be called after ColumnSourceManager.initialize(). The returned table will also have columns corresponding to the partitions found in the locations, for the convenience of many downstream operations.

Specified by:

locationTable in interface ColumnSourceManager

Returns:

The added locations that have been found to exist and have non-zero size

locationColumnName

public String locationColumnName()

Description copied from interface: ColumnSourceManager

Get the name of the column that contains the TableLocation values from ColumnSourceManager.locationTable().

Specified by:

locationColumnName in interface ColumnSourceManager

Returns:

The name of the location column

rowSetColumnName

public String rowSetColumnName()

Description copied from interface: ColumnSourceManager

Get the name of the column that contains the RowSet values from ColumnSourceManager.locationTable().

Specified by:

rowSetColumnName in interface ColumnSourceManager

Returns:

The name of the row set column

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 interface ColumnSourceManager

Returns:

True if there are no included locations

getColumnSources

public final Map<String,? extends ColumnSource<?>> getColumnSources()

Description copied from interface: ColumnSourceManager

Get a map of name to ColumnSource for the column sources maintained by this manager.

Specified by:

getColumnSources in interface ColumnSourceManager

Returns:

An unmodifiable view of the column source map maintained by this manager.

asLivenessNode

public LivenessNode asLivenessNode()

Description copied from interface: DelegatingLivenessNode

Returns the "real" LivenessNode instance. When implementing this, care should be taken to match lifecycle of the DelegatingLivenessNode instance with this instance, as the returned LivenessNode behaves as a proxy for this.

Specified by:

asLivenessNode in interface DelegatingLivenessNode

Returns:

a LivenessNode to use to manage this object's liveness.

getTableAttributes

public Map<String,Object> getTableAttributes(@NotNull
 @NotNull TableUpdateMode tableUpdateMode,
 @NotNull
 @NotNull TableUpdateMode tableLocationUpdateMode)

Description copied from interface: ColumnSourceManager

Get a map of Table attributes that can be applied to the output source table, given the update modes of the underlying table location provider.

Specified by:

getTableAttributes in interface ColumnSourceManager

Parameters:

tableUpdateMode - The update mode of the table location set

tableLocationUpdateMode - The update mode of the table location rows