Package io.deephaven.engine.table.impl
package io.deephaven.engine.table.impl
-
ClassDescriptionEncapsulate some hacky conventions we use to "standardize" absolute value sorting directives from the UI.AbstractColumnSource.DefaultedImmutable<DATA_TYPE>AbstractColumnSource.DefaultedMutable<DATA_TYPE>BaseGridAttributes<IFACE_TYPE extends GridAttributes<IFACE_TYPE>,
IMPL_TYPE extends BaseGridAttributes<IFACE_TYPE, IMPL_TYPE>> Default implementation forGridAttributes.Base abstract class all standard table implementations.Simplest appropriate InstrumentedShiftAwareListener implementation for BaseTable and descendants.Simplest appropriate legacy ShiftObliviousInstrumentedListener implementation for BaseTable and descendants.Tools for manipulating blink tables.Utility class to concentrateObjectCodeclookups.Defaulted interfaces for various baseColumnSourcetypes, in order to avoid having defaults at higher levels in the class hierarchy.Default interface for BooleanColumnSourceimplementations.Default interface for byteColumnSourceimplementations.Default interface for charColumnSourceimplementations.Default interface for doubleColumnSourceimplementations.Default interface for floatColumnSourceimplementations.Default interface for intColumnSourceimplementations.Default interface for longColumnSourceimplementations.Default interface forInstantColumnSourceimplementations.ColumnSourceGetDefaults.ForObject<DATA_TYPE>Default interface for ObjectColumnSourceimplementations.Default interface for shortColumnSourceimplementations.ColumnSourceGetDefaults.LongBacked<DATA_TYPE>Default interface for long-backedColumnSourceimplementations.Manager for ColumnSources in a Table.A ConstituentDependency is used to establish adependencyrelationship between a table and the constituent tables (or table-like things) that fill its columns.Implementation for chunk-oriented joins that produce multiple RHS rows per-LHS row, includingTableOperations.join(TABLE)(referred to as simply join or "cross join") and a left outer join.Shift state used by theBitShiftingColumnSource.DefaultChunkSource<ATTR extends Any>DefaultChunkSource.SupportsContiguousGet<ATTR extends Any>An alternative set of defaults which may typically be used byChunkSources which support a get method which only works for contiguous ranges.DefaultChunkSource.WithPrev<ATTR extends Any>DefaultGetContext<ATTR extends Any>An uncoalesced table with view and where operations to be applied afterUncoalescedTable.coalesce()is forced.The table reference hides the table underlying table from us.An interface for things that provide a stream of dependencies.Implementation ofOperationInitializerthat delegates to aForkJoinPool.Annotations library for the column-oriented hash tables used by join and aggregation operations.We tag the empty state variable with this annotation, so we know what its name is in the source and destination.We tag the overflow state ColumnSource with this annotation, so we know what its name is in the source and destination.We tag the state ColumnSource with this annotation, so we know what its name is in the source and destination.ImmutableColumnSource<DATA_TYPE>Sub-interface ofColumnSourcefor implementations that always use returntruefromImmutableColumnSource.isImmutable()and delegate allgetPrev*methods to their current (non-previous) equivalents.Defaulted interfaces for various immutableColumnSourcetypes, in order to avoid having defaults at higher levels in the class hierarchy.Default interface for immutable BooleanColumnSourceimplementations.Default interface for immutable byteColumnSourceimplementations.Default interface for immutable charColumnSourceimplementations.Default interface for immutable doubleColumnSourceimplementations.Default interface for immutable floatColumnSourceimplementations.Default interface for immutable intColumnSourceimplementations.Default interface for immutable longColumnSourceimplementations.Default interface for immutableInstantColumnSourceimplementations.ImmutableColumnSourceGetDefaults.ForObject<DATA_TYPE>Default interface for immutable ObjectColumnSourceimplementations.Default interface for immutable shortColumnSourceimplementations.ImmutableColumnSourceGetDefaults.LongBacked<DATA_TYPE>Default interface for immutable long-backedColumnSourceimplementations.This class is used for ShiftAwareListeners that represent "leaf" nodes in the update propagation tree.Makes a redirection index based on the type provided by the join control.This interface represents a table that will not update itself on the run cycle, but instead run itself when the run for snapshot is called.The right hand side table of a V2 snapshot must be an QueryTable (otherwise it fails with a class cast exception), but there are certain cases where we may not want that to be true (e.g., a WnUnsubscribedTable).A listener recorder stores references to added, removed, modified, and shifted indices; and then notifies aMergedListenerthat a change has occurred.LiveAttributeMap<IFACE_TYPE extends AttributeMap<IFACE_TYPE>,IMPL_TYPE extends LiveAttributeMap<IFACE_TYPE, IMPL_TYPE>> Re-usableAttributeMapimplementation that is also aLivenessArtifact.Holds a pair of column names.Indices for memoized operations on QueryTable.A merged listener has a collection ofListenerRecorders.This is a common interface for the static and incremental state manager so that our bucketed MultiJoinTable system is capable of using them interchangeably to build the table.Engine-specific implementation ofMultiJoinFactory.Creator.MutableColumnSource<DATA_TYPE>Sub-interface ofColumnSourcefor implementations that always use returnfalsefromMutableColumnSource.isImmutable().Defaulted interfaces for various mutableColumnSourcetypes, in order to avoid having defaults at higher levels in the class hierarchy.Default interface for mutable BooleanColumnSourceimplementations.Default interface for mutable byteColumnSourceimplementations.Default interface for mutable charColumnSourceimplementations.Default interface for mutable doubleColumnSourceimplementations.Default interface for mutable floatColumnSourceimplementations.Default interface for mutable intColumnSourceimplementations.Default interface for mutable longColumnSourceimplementations.Default interface for mutableInstantColumnSourceimplementations.MutableColumnSourceGetDefaults.ForObject<DATA_TYPE>Default interface for mutable ObjectColumnSourceimplementations.Default interface for mutable shortColumnSourceimplementations.MutableColumnSourceGetDefaults.LongBacked<DATA_TYPE>Default interface for mutable long-backedColumnSourceimplementations.A tracker for modified join hash table slots.Exception thrown when a column is not found.Used byOperationSnapshotControlto set the notification step of elements in our DAG.Elements of a Deephaven query DAG that can supply their notification step.Implementation of OperationInitializer that delegates to a pool of threads.A simple implementation ofConstructSnapshot.SnapshotControlthat uses the last notification step of the source table to determine whether to use previous values during initialization and to evaluate success.Variant ofOperationSnapshotControlthat considers "extra"dependenciesin addition to the sourceBaseTablewhen determining whether to use previous values during initialization or evaluating success.A source table that can filter partitions before coalescing.This is a niche class that allows an existingrowsetto masquerade as aRowSetBuilderRandomfor the sake of efficient processing.WrapperColumnSourcethat maps current data accessors to previous data accessors (and disables previous data accessors).A QueryCompilerRequestProcessor that batches requests and compiles them all at once.A QueryCompilerRequestProcessor that immediately compiles requests.Primary coalesced table implementation.The resulting table and listener of the operation.RedefinableTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>An uncoalesced table that may be redefined without triggering aUncoalescedTable.coalesce().Tools for creating a new ShiftedColumn(s) for a given input table and a source column(s)This class is used for Listeners that represent "leaf" nodes in the update propagation tree.Simple source table with no partitioning support.Helper class for managing the sorted columns attribute.Enum value for ascending vs.A pair representing a column to sort by and its direction.SourceTable<IMPL_TYPE extends SourceTable<IMPL_TYPE>>Basic uncoalesced table that only adds keys.Factory for source table components.A simpler version ofTableOperations.select()that is guaranteed to preserve the original table's RowSet.This column source is used as a wrapper for the original table's symbol sources.Adapter sub-interface ofTableDefaultsthat allows implementors to selectively support an opt-in subset of the typical concrete methods for aTableimplementation.Engine-specific implementation ofTableCreator.Sub-interface to capture default methods romTable.TableKeyStateRegistry<VALUE_TYPE>A registry for states keyed byTableKey.Implementation ofTableUpdate.A TimeTable adds rows at a fixed interval with a single column named "Timestamp".Factory for producing Deephaven engine TupleSource instances.Reinterpret result for manyColumnSourceimplementations that internally represent time values, such asInstant, aslongvalues.UncoalescedTable<IMPL_TYPE extends UncoalescedTable<IMPL_TYPE>>Abstract class for uncoalesced tables.A live table that allows add, remove, and modify.Interface provided to updater functions that allows RowSet changes to be recorded for propagation.Updater function interface.AQueryTablethat acts as an update source within thePeriodicUpdateGraph, withRowSetchanges queued externally by a single producer.A table operation similar toTableOperations.where(String...)except that instead of filtering the rows in the table, it appends new columns containing the result of the filter evaluation on each row of the table.