Package io.deephaven.engine.table.impl.remote

Class InitialSnapshotTable

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<IFACE_TYPE,IMPL_TYPE>

io.deephaven.engine.table.impl.BaseGridAttributes<Table,IMPL_TYPE>

io.deephaven.engine.table.impl.BaseTable<QueryTable>

io.deephaven.engine.table.impl.QueryTable

io.deephaven.engine.table.impl.remote.InitialSnapshotTable

All Implemented Interfaces:

TableOperations<Table,Table>, TableOperationsDefaults<Table,Table>, LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent, AttributeMap<Table>, GridAttributes<Table>, NotificationStepReceiver, NotificationStepSource, TableDefaults, Table, DynamicNode, NotificationQueue.Dependency, SystemicObject<Table>, LongSizedDataStructure, Serializable

public class InitialSnapshotTable
extends QueryTable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	InitialSnapshotTable.Setter<T>

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.QueryTable

QueryTable.FilteredTable, QueryTable.MemoizableOperation<T extends DynamicNode & NotificationStepReceiver>, QueryTable.Operation<T extends DynamicNode & NotificationStepReceiver>

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

Modifier and Type	Field	Description
protected int	capacity
protected WritableRowSet	freeset
protected final WritableRowSet[]	populatedCells
protected final WritableRowSet	populatedRows
protected WritableRowRedirection	rowRedirection
protected final InitialSnapshotTable.Setter<?>[]	setters
protected WritableColumnSource<?>[]	writableSources

Fields inherited from class io.deephaven.engine.table.impl.QueryTable

MINIMUM_PARALLEL_SELECT_ROWS, TRACKED_FIRST_BY, TRACKED_LAST_BY, USE_CHUNKED_CROSS_JOIN, USE_OLDER_CHUNKED_BY

Fields inherited from class io.deephaven.engine.table.impl.BaseTable

definition, description, PRINT_SERIALIZED_UPDATE_OVERLAPS, updateGraph, VALIDATE_UPDATE_OVERLAPS

Fields inherited from interface io.deephaven.engine.table.GridAttributes

COLUMN_DESCRIPTIONS_ATTRIBUTE, DESCRIPTION_ATTRIBUTE, LAYOUT_HINTS_ATTRIBUTE, SORTABLE_COLUMNS_ATTRIBUTE

Fields inherited from interface io.deephaven.engine.table.impl.NotificationStepReceiver

NULL_NOTIFICATION_STEP

Fields inherited from interface io.deephaven.engine.table.Table

ADD_ONLY_TABLE_ATTRIBUTE, AGGREGATION_ROW_LOOKUP_ATTRIBUTE, APPEND_ONLY_TABLE_ATTRIBUTE, BARRAGE_PERFORMANCE_KEY_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, SORTED_COLUMNS_ATTRIBUTE, SYSTEMIC_TABLE_ATTRIBUTE, TEST_SOURCE_TABLE_ATTRIBUTE, TOTALS_TABLE_ATTRIBUTE, UNIQUE_KEYS_ATTRIBUTE

Fields inherited from interface io.deephaven.engine.table.impl.TableDefaults

ZERO_LENGTH_TABLE_ARRAY

Fields inherited from interface io.deephaven.api.TableOperations

AGG_BY_PRESERVE_EMPTY_DEFAULT

Fields inherited from interface io.deephaven.api.TableOperationsDefaults

ZERO_LENGTH_COLUMNNAME_ARRAY, ZERO_LENGTH_FILTER_ARRAY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InitialSnapshotTable(Map<String,? extends ColumnSource<?>> result, WritableColumnSource<?>[] writableSources, WritableRowRedirection rowRedirection, BitSet subscribedColumns)

Method Summary

Modifier and Type	Method	Description
protected RowSet	getFreeRows(long size)
protected InitialSnapshotTable.Setter<?>	getSetter(WritableColumnSource source)
BitSet	getSubscribedColumns()
boolean	isSubscribedColumn(int column)
protected void	processInitialSnapshot(InitialSnapshot snapshot)
static InitialSnapshotTable	setupInitialSnapshotTable(TableDefinition definition, InitialSnapshot snapshot)
static InitialSnapshotTable	setupInitialSnapshotTable(TableDefinition definition, InitialSnapshot snapshot, BitSet subscribedColumns)
static InitialSnapshotTable	setupInitialSnapshotTable(Table originalTable, InitialSnapshot snapshot)
static InitialSnapshotTable	setupInitialSnapshotTable(Table originalTable, InitialSnapshot snapshot, BitSet subscribedColumns)

Methods inherited from class io.deephaven.engine.table.impl.QueryTable

aggAllBy, aggBy, aggNoMemo, apply, asOfJoin, byteColumnIterator, characterColumnIterator, checkInitiateBinaryOperation, checkInitiateOperation, columnIterator, copy, copy, copy, disableParallelWhereForThread, doubleColumnIterator, dropColumns, exactJoin, flatten, floatColumnIterator, getColumnSource, getColumnSourceMap, getColumnSources, getModifiedColumnSetForUpdates, getResult, getRowSet, getSubTable, getSubTable, head, headBy, headPct, integerColumnIterator, isFlat, join, lazyUpdate, longColumnIterator, memoizeResult, moveColumns, naturalJoin, newModifiedColumnSet, newModifiedColumnSetIdentityTransformer, newModifiedColumnSetIdentityTransformer, newModifiedColumnSetTransformer, newModifiedColumnSetTransformer, newModifiedColumnSetTransformer, objectColumnIterator, partitionBy, partitionedAggBy, propagateFlatness, rangeJoin, releaseCachedResources, renameColumns, reverse, rollup, select, selectDistinct, setFlat, setMemoizeResults, shortColumnIterator, silent, size, slice, slicePct, snapshot, snapshotWhen, sort, tail, tailBy, tailPct, tree, ungroup, update, updateBy, updateView, validateSelect, view, where, whereIn, whereNotIn, withDefinitionUnsafe, wouldMatch

Methods inherited from class io.deephaven.engine.table.impl.BaseTable

addParentReference, addUpdateListener, addUpdateListener, addUpdateListener, append, awaitUpdate, awaitUpdate, checkAvailableColumns, copyAttributes, copyAttributes, copySortableColumns, createSnapshotControlIfRefreshing, destroy, getDefinition, getDescription, getLastNotificationStep, getNotificationQueue, getUpdateGraph, hasListeners, initializeWithSnapshot, isAddOnly, isAppendOnly, isBlink, isFailed, isRefreshing, isSystemicObject, markSystemic, notifyListeners, notifyListeners, notifyListenersOnError, removeBlink, removeUpdateListener, removeUpdateListener, satisfied, setLastNotificationStep, setRefreshing, setTotalsTable, shouldCopyAttribute, toString, withKeys, withUniqueKeys

Methods inherited from class io.deephaven.engine.table.impl.BaseGridAttributes

clearSortingRestrictions, getSortableColumns, restrictSortTo, setColumnDescriptions, setLayoutHints, setSortableColumns, withColumnDescription, withColumnDescriptions, withDescription

Methods inherited from class io.deephaven.engine.table.impl.LiveAttributeMap

copyAttributes, getAttribute, getAttributeKeys, getAttributes, getAttributes, hasAttribute, prepareReturnCopy, prepareReturnThis, published, retainingAttributes, setAttribute, setAttribute, withAttributes, withAttributes, withoutAttributes

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

dropReference, tryRetainReference

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

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.table.AttributeMap

getAttribute, getAttributeKeys, getAttributes, getAttributes, hasAttribute, retainingAttributes, withAttributes, withAttributes, withoutAttributes

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

clearSortingRestrictions, restrictSortTo, setLayoutHints, withColumnDescription, withColumnDescriptions, withDescription

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.util.datastructures.LongSizedDataStructure

intSize, intSize

Methods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency

getUpdateGraph

Methods inherited from interface io.deephaven.engine.table.impl.TableDefaults

addUpdateListener, applyToAllBy, applyToAllBy, applyToAllBy, close, coalesce, dropColumnFormats, formatColumns, formatColumnWhere, formatRowWhere, getColumnSource, getColumnSource, hasColumns, hasColumns, headBy, isEmpty, join, meta, moveColumns, moveColumnsDown, moveColumnsUp, numColumns, partitionBy, renameAllColumns, renameColumns, rollup, rollup, rollup, rollup, rollup, selectDistinct, sizeForInstrumentation, snapshotWhen, snapshotWhen, tailBy, wouldMatch

Methods 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, lastBy, lastBy, lastBy, lastBy, lazyUpdate, maxBy, maxBy, maxBy, maxBy, medianBy, medianBy, medianBy, medianBy, minBy, minBy, minBy, minBy, 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

Field Details

setters

protected final InitialSnapshotTable.Setter<?>[] setters

capacity

protected int capacity

freeset

protected WritableRowSet freeset

populatedRows

protected final WritableRowSet populatedRows

populatedCells

protected final WritableRowSet[] populatedCells

writableSources

protected WritableColumnSource<?>[] writableSources

rowRedirection

protected WritableRowRedirection rowRedirection

Constructor Details

InitialSnapshotTable

protected InitialSnapshotTable(Map<String,? extends ColumnSource<?>> result,
 WritableColumnSource<?>[] writableSources,
 WritableRowRedirection rowRedirection,
 BitSet subscribedColumns)

Method Details

getSubscribedColumns

public BitSet getSubscribedColumns()

isSubscribedColumn

public boolean isSubscribedColumn(int column)

getSetter

protected InitialSnapshotTable.Setter<?> getSetter(WritableColumnSource source)

processInitialSnapshot

protected void processInitialSnapshot(InitialSnapshot snapshot)

getFreeRows

protected RowSet getFreeRows(long size)

setupInitialSnapshotTable

public static InitialSnapshotTable setupInitialSnapshotTable(Table originalTable,
 InitialSnapshot snapshot)

setupInitialSnapshotTable

public static InitialSnapshotTable setupInitialSnapshotTable(Table originalTable,
 InitialSnapshot snapshot,
 BitSet subscribedColumns)

setupInitialSnapshotTable

public static InitialSnapshotTable setupInitialSnapshotTable(TableDefinition definition,
 InitialSnapshot snapshot)

setupInitialSnapshotTable

public static InitialSnapshotTable setupInitialSnapshotTable(TableDefinition definition,
 InitialSnapshot snapshot,
 BitSet subscribedColumns)