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, @NotNull UnaryOperator<Table> applyTablePermissions, @NotNull TableLocationProvider tableLocationProvider, boolean refreshLocations, boolean refreshSizes, @NotNull Predicate<ImmutableTableLocationKey> locationKeyMatcher)	Construct a SourcePartitionedTable from the supplied parameters.

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

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

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,
 @NotNull
 @NotNull UnaryOperator<Table> applyTablePermissions,
 @NotNull
 @NotNull TableLocationProvider tableLocationProvider,
 boolean refreshLocations,
 boolean refreshSizes,
 @NotNull
 @NotNull Predicate<ImmutableTableLocationKey> locationKeyMatcher)

Construct a SourcePartitionedTable from the supplied parameters.

Note that refreshLocations and refreshSizes are distinct because there are use cases that supply an external RowSet and hence don't require size refreshes. Others might care for size refreshes, but only the initially-available set of locations.

Parameters:

constituentDefinition - The TableDefinition expected of constituent tables

applyTablePermissions - Function to apply in order to correctly restrict the visible result rows

tableLocationProvider - Source for table locations

refreshLocations - Whether the set of locations should be refreshed

refreshSizes - Whether the locations found should be refreshed

locationKeyMatcher - Function to filter desired location keys