Package com.illumon.iris.db.v2.utils

Class KeyedArrayBackedMutableTable

java.lang.Object

com.illumon.util.referencecounting.ReferenceCounted

com.illumon.iris.db.util.liveness.LivenessArtifact

com.illumon.iris.db.v2.BaseTable

com.illumon.iris.db.v2.QueryTable

com.illumon.iris.db.v2.UpdatableTable

com.illumon.iris.db.v2.utils.KeyedArrayBackedMutableTable

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, LiveTable, NotificationQueue.Dependency, Deflatable<Table>, Table, LivenessManager, LivenessNode, LivenessReferent, LongSizedDataStructure, DynamicNode, DynamicTable, NotificationStepReceiver, NotificationStepSource, SystemicObject, Serializable

public class KeyedArrayBackedMutableTable
extends UpdatableTable

An in-memory table that has keys for each row, which can be updated on the LTM. This is used to implement in-memory editable table columns from web plugins.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.UpdatableTable

UpdatableTable.IndexChangeRecorder, UpdatableTable.Updater

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.QueryTable

QueryTable.FilteredTable, QueryTable.MemoizableOperation, QueryTable.Operation

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.BaseTable

BaseTable.CopyAttributeOperation, BaseTable.ListenerImpl, BaseTable.ShiftAwareListenerImpl, BaseTable.SwapListenerFactory<T extends SwapListenerBase>

Nested classes/interfaces inherited from interface com.illumon.iris.db.tables.Table

Table.AsOfMatchRule, Table.GroupStrategy, Table.RenameFunction

Field Summary

Fields

Modifier and Type	Field	Description
protected ObjectArraySource<?>[]	arrayValueSources
protected com.illumon.iris.web.shared.data.InputTableDefinition	inputTableDefinition

Fields inherited from class com.illumon.iris.db.v2.QueryTable

modifiedColumnSet, USE_CHUNKED_CROSS_JOIN, USE_UNTRACKED_LASTBY_FOR_AUTOMATED_FILTERS

Fields inherited from class com.illumon.iris.db.v2.BaseTable

attributes, definition, PRINT_SERIALIZED_UPDATE_OVERLAPS

Fields inherited from interface com.illumon.iris.db.v2.NotificationStepReceiver

NULL_NOTIFICATION_STEP

Fields inherited from interface com.illumon.iris.db.tables.Table

ACL_ATTRIBUTE, ADD_ONLY_TABLE_ATTRIBUTE, COLUMN_DESCRIPTIONS_ATTRIBUTE, COLUMN_RENDERERS_ATTRIBUTE, CUSTOM_ACTIONS_ATTRIBUTE, DO_NOT_MAKE_REMOTE_ATTRIBUTE, EMPTY_SOURCE_TABLE_ATTRIBUTE, FILTERABLE_COLUMNS_ATTRIBUTE, HIERARCHICAL_CHILDREN_TABLE_MAP_ATTRIBUTE, HIERARCHICAL_SOURCE_INFO_ATTRIBUTE, HIERARCHICAL_SOURCE_TABLE_ATTRIBUTE, INPUT_TABLE_ATTRIBUTE, KEY_COLUMNS_ATTRIBUTE, LAYOUT_HINTS_ATTRIBUTE, MERGED_TABLE_ATTRIBUTE, NON_DISPLAY_TABLE, PLUGIN_NAME, PREDEFINED_ROLLUP_ATTRIBUTE, PREEMPTIVE_VIEWPORT_TYPE, PREPARED_RLL_ATTRIBUTE, PREVIEW_PARENT_TABLE, REVERSE_LOOKUP_ATTRIBUTE, ROLLUP_LEAF_ATTRIBUTE, SNAPSHOT_VIEWPORT_TYPE, SORTABLE_COLUMNS_ATTRIBUTE, SORTED_COLUMNS_ATTRIBUTE, SYSTEMIC_TABLE_ATTRIBUTE, TABLE_DESCRIPTION_ATTRIBUTE, TOTALS_TABLE_ATTRIBUTE, TREE_TABLE_FILTER_REVERSE_LOOKUP_ATTRIBUTE, UNIQUE_KEYS_ATTRIBUTE, UNTRACKED_LASTBY_TABLE_ATTRIBUTE, VIEWPORT_TYPE_ATTRIBUTE, ZERO_LENGTH_TABLE_ARRAY

Method Summary

Modifier and Type	Method	Description
void	dropReference()	Drop a previously-retained reference to this referent.
protected String	getDefaultDescription()
WeakReference<? extends LivenessReferent>	getWeakReference()	Get a WeakReference to this referent.
void	initializeTransientFieldsForLiveness()	Package-private for Serializable sub-classes to use in readObject only.
static KeyedArrayBackedMutableTable	make(TableDefinition definition, String... keyColumnNames)	Create an empty KeyedArrayBackedMutableTable.
static KeyedArrayBackedMutableTable	make(TableDefinition definition, Map<String,Object[]> enumValues, String... keyColumnNames)	Create an empty KeyedArrayBackedMutableTable.
static KeyedArrayBackedMutableTable	make(Table initialTable, String... keyColumnNames)	Create an empty KeyedArrayBackedMutableTable.
static KeyedArrayBackedMutableTable	make(Table initialTable, Map<String,Object[]> enumValues, String... keyColumnNames)	Create an empty KeyedArrayBackedMutableTable.
protected static Map<String,? extends ArrayBackedColumnSource<?>>	makeColumnSourceMap(TableDefinition definition)
protected void	onReferenceCountAtZero()	Callback method that will be invoked when the reference count returns to zero.
protected void	processPendingDelete(Table table, UpdatableTable.IndexChangeRecorder indexChangeRecorder)
protected void	processPendingTable(Table table, boolean allowEdits, UpdatableTable.IndexChangeRecorder indexChangeRecorder, Consumer<String> errorNotifier)
void	refresh()	Refresh this LiveTable.
com.illumon.iris.db.v2.utils.BaseArrayBackedMutableTable	setDescription(String newDescription)
boolean	tryManage(LivenessReferent referent)	Attempt to add the specified referent to this manager.
boolean	tryRetainReference()	If this referent is "live", behave as LivenessReferent.retainReference() and return true.

Methods inherited from class com.illumon.iris.db.v2.UpdatableTable

destroy, doNotifyListeners

Methods inherited from class com.illumon.iris.db.v2.QueryTable

absSumBy, addColumnGrouping, aj, apply, applyToAllBy, avgBy, by, byExternal, copy, copy, countBy, disableParallelWhereForThread, disableWriteReplace, dropColumns, enableWriteReplace, exactJoin, firstBy, flatten, getColumn, getColumnSource, getColumnSourceMap, getColumnSources, getDataIndex, getIndex, getModifiedColumnSetForUpdates, getRecord, getSubTable, getSubTable, head, headBy, headPct, isFlat, join, lastBy, lazyUpdate, leftJoin, maxBy, medianBy, memoizeResult, minBy, naturalJoin, newModifiedColumnSet, newModifiedColumnSetIdentityTransformer, newModifiedColumnSetIdentityTransformer, newModifiedColumnSetTransformer, preemptiveSnapshotTable, preemptiveUpdatesTable, preemptiveUpdatesTable, raj, releaseCachedResources, renameColumns, reverse, rollup, select, selectDistinct, setDataIndexProvider, setFlat, setMemoizeResults, silent, size, slice, snapshot, snapshotHistory, snapshotIncremental, sort, stdBy, sumBy, tail, tailBy, tailPct, treeTable, ungroup, update, updateBy, updateView, validateSelect, varBy, view, wavgBy, where, whereIn, wouldMatch, wsumBy

Methods inherited from class com.illumon.iris.db.v2.BaseTable

addParentReference, append, awaitUpdate, awaitUpdate, clearSortingRestrictions, copyAttributes, copyAttributes, createSwapListenerIfRefreshing, getAttribute, getAttributeNames, getAttributes, getDefinition, getDescription, getLastNotificationStep, getNotificationQueue, hasAttribute, initializeWithSnapshot, isAddOnly, isAddOnly, isFailed, isRefreshing, isSystemicObject, layoutHints, listenForDirectUpdates, listenForUpdates, listenForUpdates, markSystemic, notifyListeners, notifyListenersOnError, removeDirectUpdateListener, removeUpdateListener, removeUpdateListener, restrictSortTo, satisfied, setAttribute, setColumnRenderers, setLastNotificationStep, setRefreshing, setTotalsTable, shouldCopyAttribute, toString, withColumnDescription, withKeys, withTableDescription, withUniqueKeys

Methods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact

manageWithCurrentScope, unmanage, unmanage

Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted

decrementReferenceCount, 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 com.illumon.iris.db.v2.DynamicTable

listenForUpdates, newModifiedColumnSetTransformer, newModifiedColumnSetTransformer, notifyListeners

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessManager

manage, tryManage

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

Methods inherited from interface com.illumon.iris.db.util.LongSizedDataStructure

intSize, intSize

Methods inherited from interface com.illumon.iris.db.tables.Table

absSumBy, absSumBy, absSumBy, aj, aj, aj, aj, aj, applyToAllBy, applyToAllBy, applyToAllBy, avgBy, avgBy, avgBy, by, by, by, by, by, by, byExternal, byteColumnIterator, characterColumnIterator, close, coalesce, columnIterator, countBy, countBy, countBy, dateTimeColumnAsNanos, dateTimeColumnAsNanos, deflate, deflate, doubleColumnIterator, dropColumnFormats, dropColumns, exactJoin, exactJoin, exactJoin, exactJoin, firstBy, firstBy, firstBy, floatColumnIterator, formatColumns, formatColumnWhere, formatRowWhere, getAttributes, getColumn, getColumns, getColumnSource, getMeta, getViewPort, hasColumns, hasColumns, headBy, headBy, integerColumnIterator, isEmpty, isLive, join, join, join, join, join, join, join, join, join, lastBy, lastBy, lastBy, layoutHints, lazyUpdate, lazyUpdate, leftJoin, leftJoin, leftJoin, leftJoin, leftJoin, longColumnIterator, maxBy, maxBy, maxBy, medianBy, medianBy, medianBy, minBy, minBy, minBy, moveColumns, moveColumns, moveDownColumns, moveUpColumns, naturalJoin, naturalJoin, naturalJoin, naturalJoin, preemptiveSnapshotTable, raj, raj, raj, raj, raj, renameAllColumns, renameColumns, renameColumns, rollup, rollup, rollup, rollup, rollup, rollup, rollup, select, select, select, selectDistinct, selectDistinct, selectDistinct, shortColumnIterator, sizeForInstrumentation, snapshot, snapshotIncremental, sort, sort, sortDescending, sortDescending, stdBy, stdBy, stdBy, subscribeToPreemptiveUpdates, sumBy, sumBy, sumBy, supportsPreemptiveSubscription, tailBy, tailBy, ungroup, ungroup, ungroup, ungroupAllBut, update, update, updateBy, updateBy, updateBy, updateBy, updateBy, updateView, updateView, validateSelect, varBy, varBy, varBy, view, view, wavgBy, wavgBy, wavgBy, where, where, where, whereDynamic, whereDynamicIn, whereDynamicIn, whereDynamicNotIn, whereDynamicNotIn, whereIn, whereIn, whereIn, whereIn, whereIn, whereIn, whereIn, whereNotIn, whereNotIn, whereNotIn, whereNotIn, whereOneOf, whereOneOf, whereOneOf, withColumnDescription, wouldMatch, wsumBy, wsumBy, wsumBy

Field Details

arrayValueSources

protected final ObjectArraySource<?>[] arrayValueSources

inputTableDefinition

protected final com.illumon.iris.web.shared.data.InputTableDefinition inputTableDefinition

Method Details

make

public static KeyedArrayBackedMutableTable make(@NotNull TableDefinition definition, String... keyColumnNames)

Create an empty KeyedArrayBackedMutableTable.

Parameters:

definition - the definition of the table to create

keyColumnNames - the name of the key columns

Returns:

an empty KeyedArrayBackedMutableTable with the given definition and key columns

make

public static KeyedArrayBackedMutableTable make(@NotNull TableDefinition definition, Map<String,Object[]> enumValues, String... keyColumnNames)

Create an empty KeyedArrayBackedMutableTable.

Parameters:

definition - the definition of the table to create

enumValues - a map of column names to enumeration values

keyColumnNames - the name of the key columns

Returns:

an empty KeyedArrayBackedMutableTable with the given definition and key columns

make

public static KeyedArrayBackedMutableTable make(Table initialTable, String... keyColumnNames)

Create an empty KeyedArrayBackedMutableTable. The initialTable is processed in order, so if there are duplicate keys only the last row is reflected in the output.

Parameters:

initialTable - the initial values to copy into the KeyedArrayBackedMutableTable

keyColumnNames - the name of the key columns

Returns:

an empty KeyedArrayBackedMutableTable with the given definition and key columns

make

public static KeyedArrayBackedMutableTable make(Table initialTable, Map<String,Object[]> enumValues, String... keyColumnNames)

Create an empty KeyedArrayBackedMutableTable. The initialTable is processed in order, so if there are duplicate keys only the last row is reflected in the output.

Parameters:

initialTable - the initial values to copy into the KeyedArrayBackedMutableTable

enumValues - a map of column names to enumeration values

keyColumnNames - the name of the key columns

Returns:

an empty KeyedArrayBackedMutableTable with the given definition and key columns

processPendingTable

protected void processPendingTable(Table table, boolean allowEdits, UpdatableTable.IndexChangeRecorder indexChangeRecorder, Consumer<String> errorNotifier)

processPendingDelete

protected void processPendingDelete(Table table, UpdatableTable.IndexChangeRecorder indexChangeRecorder)

getDefaultDescription

protected String getDefaultDescription()

makeColumnSourceMap

protected static Map<String,? extends ArrayBackedColumnSource<?>> makeColumnSourceMap(TableDefinition definition)

setDescription

public com.illumon.iris.db.v2.utils.BaseArrayBackedMutableTable setDescription(String newDescription)

refresh

public void refresh()

Description copied from interface: LiveTable

Refresh this LiveTable.

Specified by:

refresh in interface LiveTable

Overrides:

refresh in class UpdatableTable

initializeTransientFieldsForLiveness

@VisibleForTesting public final void initializeTransientFieldsForLiveness()

Package-private for Serializable sub-classes to use in readObject only. Public to allow unit tests in another package to work around mock issues where the constructor is never invoked.

tryRetainReference

public final boolean tryRetainReference()

Description copied from interface: LivenessReferent

If this referent is "live", behave as LivenessReferent.retainReference() and return true. Otherwise, returns false rather than throwing an exception.

Specified by:

tryRetainReference in interface LivenessReferent

Returns:

True if this referent was retained, false otherwise

dropReference

public final void dropReference()

Description copied from interface: LivenessReferent

Drop a previously-retained reference to this referent.

Specified by:

dropReference in interface LivenessReferent

getWeakReference

public WeakReference<? extends LivenessReferent> getWeakReference()

Description copied from interface: LivenessReferent

Get a WeakReference to this referent. This may be cached, or newly created.

Specified by:

getWeakReference in interface LivenessReferent

Returns:

A new or cached reference to this referent

tryManage

public final boolean tryManage(@NotNull LivenessReferent referent)

Description copied from interface: LivenessManager

Attempt to add the specified referent to this manager.

Specified by:

tryManage in interface LivenessManager

Parameters:

referent - The referent to add

Returns:

Whether the referent was in fact added

onReferenceCountAtZero

protected final void onReferenceCountAtZero()

Description copied from class: ReferenceCounted

Callback method that will be invoked when the reference count returns to zero.

Specified by:

onReferenceCountAtZero in class ReferenceCounted