Package io.deephaven.engine.table.impl

Class SourcePartitionedTable

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

io.deephaven.engine.liveness.ReferenceCountedLivenessNode

io.deephaven.engine.liveness.LivenessArtifact

io.deephaven.engine.table.impl.partitioned.PartitionedTableImpl

io.deephaven.engine.table.impl.SourcePartitionedTable

All Implemented Interfaces:

LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, PartitionedTable, Serializable

public class SourcePartitionedTable
extends PartitionedTableImpl

PartitionedTable of single-location SourceTables keyed by TableLocationKey. Refer to TableLocationKey for an explanation of partitioning.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.table.PartitionedTable

PartitionedTable.Proxy

Constructor Summary

Constructors

Constructor	Description
SourcePartitionedTable(@NotNull TableDefinition constituentDefinition, @Nullable UnaryOperator<Table> constituentTransformer, @NotNull TableLocationProvider tableLocationProvider, boolean subscribeToTableLocationProvider, boolean subscribeToTableLocations, @Nullable Predicate<ImmutableTableLocationKey> locationKeyMatcher)	Construct a SourcePartitionedTable from the supplied parameters, excluding empty locations.

Method Summary

Methods inherited from class io.deephaven.engine.table.impl.partitioned.PartitionedTableImpl

constituentChangesPermitted, constituentColumnName, constituentDefinition, constituentFor, constituents, filter, keyColumnNames, merge, partitionedTransform, proxy, sort, table, toString, transform, uniqueKeys

Methods inherited from class io.deephaven.engine.liveness.LivenessArtifact

manageWithCurrentScope

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode

getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

destroy, dropReference, tryRetainReference

Methods inherited from class io.deephaven.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

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

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

manage, tryManage, tryUnmanage, tryUnmanage, unmanage, unmanage

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

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

Methods inherited from interface io.deephaven.base.log.LogOutputAppendable

append

Methods inherited from interface io.deephaven.engine.table.PartitionedTable

partitionedTransform, proxy, transform

Constructor Details

SourcePartitionedTable

public SourcePartitionedTable(@NotNull
 @NotNull TableDefinition constituentDefinition,
 @Nullable
 @Nullable UnaryOperator<Table> constituentTransformer,
 @NotNull
 @NotNull TableLocationProvider tableLocationProvider,
 boolean subscribeToTableLocationProvider,
 boolean subscribeToTableLocations,
 @Nullable
 @Nullable Predicate<ImmutableTableLocationKey> locationKeyMatcher)

Construct a SourcePartitionedTable from the supplied parameters, excluding empty locations.

Note that subscribeToTableLocationProvider and subscribeToTableLocations are distinct because there may be use cases that supply their own RowSet for constituents. Others might care to observe changes to constituent rows, but only the initially-available set of locations.

Parameters:

constituentDefinition - The TableDefinition expected of constituent tables

constituentTransformer - Function to apply to each "raw" constituent before making the result available to downstream consumers. This may be used, for example, in order to correctly restrict the visible result rows in constituent tables. May be null if no transformations are needed. Must not return null tables, or tables with a definition that does not match constituentDefinition.

tableLocationProvider - Source for table locations

subscribeToTableLocationProvider - Whether changes to the set of available locations after instantiation should be reflected in the result SourcePartitionedTable; that is, whether constituents should be added or removed

subscribeToTableLocations - Whether constituents should be updated to reflect changes in their available rows

locationKeyMatcher - Function to filter desired location keys; only locations for which test returns true will be included; may be null to include all