Package io.deephaven.engine.table.impl
Class RedefinableTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>
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.LiveAttributeMap<Table,IMPL_TYPE>
io.deephaven.engine.table.impl.BaseGridAttributes<Table,IMPL_TYPE>
io.deephaven.engine.table.impl.BaseTable<IMPL_TYPE>
io.deephaven.engine.table.impl.UncoalescedTable<IMPL_TYPE>
io.deephaven.engine.table.impl.UncoalescedTableImpl<IMPL_TYPE>
io.deephaven.engine.table.impl.RedefinableTable<IMPL_TYPE>
- All Implemented Interfaces:
TableOperations<Table,,Table> TableOperationsDefaults<Table,,Table> LogOutputAppendable,LivenessManager,LivenessNode,LivenessReferent,AttributeMap<Table>,GridAttributes<Table>,HasParentPerformanceIds,NotificationStepReceiver,NotificationStepSource,TableDefaults,Table,DynamicNode,NotificationQueue.Dependency,SystemicObject<Table>,LongSizedDataStructure,Serializable
- Direct Known Subclasses:
DeferredViewTable,SourceTable
public abstract class RedefinableTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>
extends UncoalescedTableImpl<IMPL_TYPE>
An uncoalesced table that may be redefined without triggering a
UncoalescedTableImpl.coalesce().- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.BaseTable
BaseTable.CopyAttributeOperation, BaseTable.ListenerImpl, BaseTable.ShiftObliviousListenerImpl, BaseTable.SnapshotControlFactory<T extends ConstructSnapshot.SnapshotControl> -
Field Summary
Fields inherited from class io.deephaven.engine.table.impl.BaseTable
definition, PRINT_SERIALIZED_UPDATE_OVERLAPS, updateGraph, VALIDATE_UPDATE_OVERLAPSFields inherited from interface io.deephaven.engine.table.GridAttributes
COLUMN_DESCRIPTIONS_ATTRIBUTE, DESCRIPTION_ATTRIBUTE, LAYOUT_HINTS_ATTRIBUTE, SORTABLE_COLUMNS_ATTRIBUTEFields inherited from interface io.deephaven.engine.table.impl.NotificationStepReceiver
NULL_NOTIFICATION_STEPFields inherited from interface io.deephaven.engine.table.Table
ADD_ONLY_TABLE_ATTRIBUTE, AGGREGATION_ROW_LOOKUP_ATTRIBUTE, APPEND_ONLY_TABLE_ATTRIBUTE, BARRAGE_PERFORMANCE_KEY_ATTRIBUTE, BARRAGE_SCHEMA_ATTRIBUTE, BLINK_TABLE_ATTRIBUTE, FILTERABLE_COLUMNS_ATTRIBUTE, INITIALLY_EMPTY_COALESCED_SOURCE_TABLE_ATTRIBUTE, INPUT_TABLE_ATTRIBUTE, KEY_COLUMNS_ATTRIBUTE, MERGED_TABLE_ATTRIBUTE, NON_DISPLAY_TABLE, PLUGIN_NAME, PREVIEW_PARENT_TABLE, SNAPSHOT_VIEWPORT_TYPE, SORT_REVERSE_LOOKUP_ATTRIBUTE, SORT_ROW_REDIRECTION_ATTRIBUTE, SORTED_COLUMNS_ATTRIBUTE, SYSTEMIC_TABLE_ATTRIBUTE, TEST_SOURCE_TABLE_ATTRIBUTE, TOTALS_TABLE_ATTRIBUTE, TRANSPORT_COMPRESSION_ATTRIBUTE, UNIQUE_KEYS_ATTRIBUTEFields inherited from interface io.deephaven.engine.table.impl.TableDefaults
ZERO_LENGTH_TABLE_ARRAYFields inherited from interface io.deephaven.api.TableOperations
AGG_BY_PRESERVE_EMPTY_DEFAULTFields inherited from interface io.deephaven.api.TableOperationsDefaults
ZERO_LENGTH_COLUMNNAME_ARRAY, ZERO_LENGTH_FILTER_ARRAY -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedRedefinableTable(@NotNull TableDefinition definition, @NotNull String description, @Nullable Map<String, Object> attributes) -
Method Summary
Modifier and TypeMethodDescriptiondropColumns(String... columnNames) Creates a new table without thecolumnNamesfromthis.protected final BaseTable<?> redefine(TableDefinition newDefinition) Redefine this table with a subset of its current columns.protected abstract Tableredefine(TableDefinition newDefinitionExternal, TableDefinition newDefinitionInternal, SelectColumn[] viewColumns) Redefine this table with a subset of its current columns, with a potentially-differing definition to present to external interfaces and one or more select columns to apply.protected abstract BaseTable<?> redefineImpl(TableDefinition newDefinition) Redefine this table with a proper-subset, or re-ordering, of its current columns.protected abstract TableredefineWithRename(TableDefinition newDefinitionExternal, SourceColumn[] renameColumns) Redefine this table by renaming the table's columns.renameColumns(Collection<Pair> pairs) Produce a new table with the specified columns renamed using the specifiedpairs.updateView(Collection<? extends Selectable> selectables) view(Collection<? extends Selectable> selectables) Methods inherited from class io.deephaven.engine.table.impl.UncoalescedTableImpl
coalesce, coalescedIfAvailable, doCoalesce, getCoalesced, setCoalescedMethods inherited from class io.deephaven.engine.table.impl.UncoalescedTable
addUpdateListener, addUpdateListener, addUpdateListener, addUpdateListenerUncoalesced, addUpdateListenerUncoalesced, aggAllBy, aggBy, apply, asOfJoin, awaitUpdate, awaitUpdate, byteColumnIterator, characterColumnIterator, columnIterator, doubleColumnIterator, exactJoin, flatten, floatColumnIterator, getColumnSource, getColumnSourceMap, getColumnSources, getRowSet, getSubTable, head, headBy, headPct, integerColumnIterator, isFlat, join, lazyUpdate, longColumnIterator, moveColumns, naturalJoin, objectColumnIterator, objectColumnIterator, partitionBy, partitionedAggBy, rangeJoin, removeUpdateListener, removeUpdateListener, removeUpdateListenerUncoalesced, reverse, rollup, select, selectDistinct, shortColumnIterator, size, sizeForInstrumentation, slice, slicePct, snapshot, snapshotWhen, sort, tail, tailBy, tailPct, tree, ungroup, update, updateBy, verifyCoalescedForReuse, where, whereIn, whereNotIn, wouldMatchMethods inherited from class io.deephaven.engine.table.impl.BaseTable
addParentReference, append, assertAddOnly, assertAppendOnly, assertBlink, checkAvailableColumns, copyAttributes, copyAttributes, copySortableColumns, createSnapshotControlIfRefreshing, currentThreadMustNotWaitForOtherThreads, destroy, getDefinition, getDescription, getLastNotificationStep, getNotificationQueue, getUpdateGraph, hasListeners, initializeWithSnapshot, isAddOnly, isAppendOnly, isBlink, isFailed, isRefreshing, isSystemicObject, markSystemic, notifyListeners, notifyListeners, notifyListenersOnError, parentPerformanceEntryIds, removeBlink, satisfied, setLastNotificationStep, setRefreshing, setTotalsTable, shouldCopyAttribute, toString, withKeys, withUniqueKeysMethods inherited from class io.deephaven.engine.table.impl.BaseGridAttributes
clearSortingRestrictions, getSortableColumns, restrictSortTo, setColumnDescriptions, setLayoutHints, setSortableColumns, withColumnDescription, withColumnDescriptions, withDescriptionMethods inherited from class io.deephaven.engine.table.impl.LiveAttributeMap
copy, copyAttributes, getAttribute, getAttributeKeys, getAttributes, getAttributes, getAttributesToCopy, hasAttribute, prepareReturnThis, published, retainingAttributes, setAttribute, setAttribute, withAttributes, withAttributes, withoutAttributesMethods inherited from class io.deephaven.engine.liveness.LivenessArtifact
manageWithCurrentScopeMethods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode
ensureCleanupOnGC, findAnyManagedReferent, forEachManagedReference, getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanageMethods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent
dropReference, tryRetainReferenceMethods inherited from class io.deephaven.util.referencecounting.ReferenceCounted
decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCountMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface io.deephaven.engine.table.AttributeMap
getAttribute, getAttributeKeys, getAttributes, getAttributes, hasAttribute, retainingAttributes, withAttributes, withAttributes, withoutAttributesMethods inherited from interface io.deephaven.engine.table.GridAttributes
clearSortingRestrictions, restrictSortTo, setLayoutHints, withColumnDescription, withColumnDescriptions, withDescriptionMethods inherited from interface io.deephaven.engine.liveness.LivenessManager
manage, tryManage, tryUnmanage, tryUnmanage, unmanage, unmanageMethods inherited from interface io.deephaven.engine.liveness.LivenessReferent
dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReferenceMethods inherited from interface io.deephaven.util.datastructures.LongSizedDataStructure
intSize, intSizeMethods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency
getUpdateGraphMethods inherited from interface io.deephaven.engine.table.impl.NotificationStepReceiver
initializeLastNotificationStepMethods inherited from interface io.deephaven.engine.table.impl.TableDefaults
addUpdateListener, applyToAllBy, applyToAllBy, applyToAllBy, close, dropColumnFormats, formatColumns, formatColumnWhere, formatRowWhere, getColumnSource, getColumnSource, getColumnSource, hasColumns, hasColumns, headBy, isEmpty, join, meta, moveColumnsDown, moveColumnsUp, numColumns, partitionBy, releaseCachedResources, renameAllColumns, renameColumns, rollup, rollup, rollup, rollup, rollup, selectDistinct, snapshotWhen, snapshotWhen, tailBy, wouldMatchMethods inherited from interface io.deephaven.api.TableOperationsDefaults
absSumBy, absSumBy, absSumBy, absSumBy, aggAllBy, aggAllBy, aggAllBy, aggBy, aggBy, aggBy, aggBy, aggBy, aggBy, aggBy, aj, aj, avgBy, avgBy, avgBy, avgBy, countBy, countBy, countBy, countBy, dropColumns, dropColumns, exactJoin, exactJoin, firstBy, firstBy, firstBy, firstBy, groupBy, groupBy, groupBy, join, join, join, join, lastBy, lastBy, lastBy, lastBy, lazyUpdate, maxBy, maxBy, maxBy, maxBy, medianBy, medianBy, medianBy, medianBy, minBy, minBy, minBy, minBy, naturalJoin, naturalJoin, naturalJoin, naturalJoin, naturalJoin, raj, raj, rangeJoin, select, select, selectDistinct, sort, sortDescending, stdBy, stdBy, stdBy, stdBy, sumBy, sumBy, sumBy, sumBy, ungroup, ungroup, ungroup, ungroup, update, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateBy, updateView, varBy, varBy, varBy, varBy, view, wavgBy, wavgBy, wavgBy, wavgBy, where, whereIn, whereNotIn, wsumBy, wsumBy, wsumBy, wsumBy
-
Constructor Details
-
RedefinableTable
protected RedefinableTable(@NotNull @NotNull TableDefinition definition, @NotNull @NotNull String description, @Nullable @Nullable Map<String, Object> attributes) - Parameters:
definition- The definition for this tabledescription- A description of this tableattributes- The attributes map to use, or elsenullto allocate a new one
-
-
Method Details
-
view
- Specified by:
viewin interfaceTableOperations<Table,Table> - Overrides:
viewin classUncoalescedTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>
-
updateView
- Specified by:
updateViewin interfaceTableOperations<Table,Table> - Overrides:
updateViewin classUncoalescedTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>
-
dropColumns
Description copied from interface:TableOperationsCreates a new table without thecolumnNamesfromthis.- Specified by:
dropColumnsin interfaceTableOperations<Table,Table> - Overrides:
dropColumnsin classUncoalescedTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>- Parameters:
columnNames- the columns to drop- Returns:
- the table
-
renameColumns
Description copied from interface:TableProduce a new table with the specified columns renamed using the specifiedpairs. The renames are simultaneous and unordered, enabling direct swaps between column names. The resulting table retains the original column ordering after applying the specified renames.NOTE: If a new column name matches an existing column that is not itself renamed, that existing column is silently dropped from the result. When the existing column is also renamed (a swap), nothing is dropped.
IllegalArgumentExceptionwill be thrown:- if a source column does not exist
- if a source column is used more than once
- if a destination column is used more than once
- Specified by:
renameColumnsin interfaceTable- Overrides:
renameColumnsin classUncoalescedTable<IMPL_TYPE extends RedefinableTable<IMPL_TYPE>>- Parameters:
pairs- The columns to rename- Returns:
- The new table, with the columns renamed
-
redefine
Redefine this table with a subset of its current columns. IfnewDefinitionhas the same column names in the same order asthistable,LiveAttributeMap.prepareReturnThis()will be returned. Delegates toredefineImpl(TableDefinition)otherwise.- Parameters:
newDefinition- A TableDefinition with a subset of this RedefinableTable's ColumnDefinitions.- Returns:
- the redefined table
-
redefineImpl
Redefine this table with a proper-subset, or re-ordering, of its current columns.- Parameters:
newDefinition- A TableDefinition with a proper-subset of this RedefinableTable's ColumnDefinitions.- Returns:
- the redefined table
-
redefine
protected abstract Table redefine(TableDefinition newDefinitionExternal, TableDefinition newDefinitionInternal, SelectColumn[] viewColumns) Redefine this table with a subset of its current columns, with a potentially-differing definition to present to external interfaces and one or more select columns to apply.- Parameters:
newDefinitionExternal- A TableDefinition that represents the results of redefine(newDefinitionInternal).view(viewColumns).newDefinitionInternal- A TableDefinition with a subset of this RedefinableTable's ColumnDefinitions.viewColumns- A set of SelectColumns to apply in order to transform a table with newDefinitionInternal to a table with newDefinitionExternal. Each column may read the result of an earlier column, as inTableOperations.view(Collection).- Returns:
- the redefined table
-
redefineWithRename
protected abstract Table redefineWithRename(TableDefinition newDefinitionExternal, SourceColumn[] renameColumns) Redefine this table by renaming the table's columns. Unlike the view columns ofredefine(TableDefinition, TableDefinition, SelectColumn[]), which apply in order, the rename columns apply simultaneously, asTable.renameColumns(Collection)requires: every rename column reads a column of this table, never the result of another rename column. Applied in order, a swap would read a column that the swap had already replaced.- Parameters:
newDefinitionExternal- A TableDefinition that represents the result of the rename.renameColumns- One SourceColumn per column of newDefinitionExternal, in the same order, each naming a column of this table to read.- Returns:
- the renamed table
-