Package com.illumon.iris.db.v2
package com.illumon.iris.db.v2
-
ClassDescriptionBase class containing common code for implementers of HierarchicalTableInfoBase abstract class all standard table implementations.Simplest appropriate legacy InstrumentedListener implementation for BaseTable and descendants.Simplest appropriate InstrumentedShiftAwareListener implementation for BaseTable and descendants.BaseTable.SwapListenerFactory<T extends SwapListenerBase>Builds and parses the directive for Table.COLUMN_RENDERERS_ATTRIBUTE.Manager for ColumnSources in a Table.Implementation for chunk-oriented joins that produce multiple RHS rows per-LHS row, including
Table.join(com.illumon.iris.db.tables.Table)(referred to as simply join or "cross join") and a left outer join.Shift state used by theBitShiftingColumnSource.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.Interface for dynamic nodes in a query's directed acyclic graph.A dynamically changing table.Divide a table evenly into slices and put the slices into a TableMap.This class is an extension of QueryTable that overrides many methods fromTablewhich are not valid to perform on Hierarchical tables (Table.treeTable(String, String)andTable.rollup(ComboAggregateFactory, String...)).A class that contains information required for a particular Hierarchical table type.IndexedDataColumn<TYPE>DataColumn implementation backed by a ColumnSource and an Index.This class is used for Listeners that represent "leaf" nodes in the update propagation tree.The basis forlistenerimplementations.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 refresh cycle, but instead refresh itself when the refresh 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).Listener for table changes.Listener for table changes.A listener recorder stores references to added, removed, modified, and shifted indices; and then notifies aMergedListenerthat a change has occurred.A very simple QueryTable that also implements LiveTable.A TableMap implementation backed by a Map.The TableMaps don't know how to create empty tables for themselves, if the TableMap needs to be pre-populated, it must pass this callback into the constructor.Keys for memoized operations on QueryTable.A merged listener has a collection ofListenerRecorders.Data structure to represent a subset of columns, used for propagating modifications viaShiftAwareListener.Updateinstances.A helper utility that simplifies propagating modified columns to a child table.Partition-aware source table with support for a single internal partition and a single column partition.If we have a set of tables, we would like to pick the highest priority table that is non-empty.Exception thrown when a column is not found.Used byswap listenersto set the notification step of elements in our DAG.Elements of a Deephaven query DAG that can supply their notification step.A source table that can filter partitions before coalescing.Primary coalesced table implementation.The resulting table and listener of the operation.An uncoalesced table that may be redefined without triggering aUncoalescedTable.coalesce().When redirectingColumnSourcesthe choice of redirection can have a significant impact on performance.This code replicator is designed to operate differently than the other replication in our system.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.For hierarchical table display, identify the row index key that corresponds to a given logical key.A null implementation of a reverse lookup, suitable for a table without any key columns.Maintains a map from key column values to their index.Copies attributes for constituent leafs or intermediate level rollups.The type of leaf nodes the rollup has.Shift-aware listener for table changes.A shift aware update structure, containing the rows and columns that were added, modified, removed, and shifted on a given cycle.Tools for creating a new ShiftedColumn(s) for a given input table and a source column(s)Simple source table with no partitioning support.Helper class for managing the sorted columns attribute.Basic uncoalesced table that only adds keys.Factory for source table components.Factory class for creatingSourceTableinstances.Factory for creatingSourceTableMaps.A simpler version ofTable.select(com.illumon.iris.db.v2.select.SelectColumn...)that is guaranteed to preserve the original table's index.Single-location simple source table.Update a clock step to at most the value contained in step.SwapListenerBase<T extends ListenerBase>Watch for ticks and when initialization is complete forward to the eventual listener.A Column source that maps Symbol table keys from an original source to new values using a lookup source.An object that can report if it is systemically important.TableKeyStateRegistry<VALUE_TYPE>A registry for states keyed byTableKey.A map of tables.Table map key change listener.Table map change listener.Get a table from aTableMapapplying approriate ACLs before returningGet a merged table of multiple keys from aTableMapapplying approriate ACLs before returningA TableMapSupplier uses a source TableMap and applies a set of operations in the get method.TableSupplier creates a Proxy to a Table with a list of Table operations to be applied when a filter method is called.
Example usage:A TimeTable adds rows at a fixed interval with a single column named "Timestamp".Defines the default aggregations and display for a totals table.This object can be merged to produce a single coalesced Table.Builder object for a TableMapProxy.Apply filters, preserving parents.Identify orphan rows in a table destined for conversion into a tree table, and mask their parent column value to null, so that they show up at the top level of the hierarchy.Abstract class for uncoalesced tables.A live table that allows add, remove, and modify.Interface provided to updater functions that allows index changes to be recorded for propagation.Updater function interface.A table operation similar toTable.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.