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

Class AppendOnlyArrayBackedMutableTable

java.lang.Object

com.illumon.util.referencecounting.ReferenceCounted

com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

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.AppendOnlyArrayBackedMutableTable

All Implemented Interfaces:

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

public class AppendOnlyArrayBackedMutableTable
extends UpdatableTable

An in-memory table that allows you to add rows as if it were an InputTable, which can be updated on the LTM. The table is not keyed, all rows are added to the end of the table. Deletions and edits are not permitted.

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 final 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, sharedAttributes

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
protected String	getDefaultDescription()
static AppendOnlyArrayBackedMutableTable	make(Table initialTable)	Create an AppendOnlyArrayBackedMutableTable with the given initial data.
static AppendOnlyArrayBackedMutableTable	make(TableDefinition definition)	Create an empty AppendOnlyArrayBackedMutableTable with the given definition.
static AppendOnlyArrayBackedMutableTable	make(TableDefinition definition, Map<String,Object[]> enumValues)	Create an empty AppendOnlyArrayBackedMutableTable with the given definition.
static AppendOnlyArrayBackedMutableTable	make(Table initialTable, Map<String,Object[]> enumValues)	Create an AppendOnlyArrayBackedMutableTable with the given initial data.
protected static Map<String,? extends ArrayBackedColumnSource<?>>	makeColumnSourceMap(TableDefinition definition)
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)

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

destroy, doNotifyListeners, refresh

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

absSumBy, 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.iris.db.util.liveness.ReferenceCountedLivenessNode

dropReference, getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryRetainReference

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.tables.live.LiveTable

run

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, whereIn, whereIn, whereIn, whereNotIn, whereNotIn, whereOneOf, whereOneOf, whereOneOf, withColumnDescription, wouldMatch, wsumBy, wsumBy, wsumBy

Field Details

inputTableDefinition

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

Method Details

make

public static AppendOnlyArrayBackedMutableTable make(@NotNull
 TableDefinition definition)

Create an empty AppendOnlyArrayBackedMutableTable with the given definition.

Parameters:

definition - the definition of the new table.

Returns:

an empty AppendOnlyArrayBackedMutableTable with the given definition

make

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

Create an empty AppendOnlyArrayBackedMutableTable with the given definition.

Parameters:

definition - the definition of the new table.

enumValues - a map of column names to enumeration values

Returns:

an empty AppendOnlyArrayBackedMutableTable with the given definition

make

public static AppendOnlyArrayBackedMutableTable make(Table initialTable)

Create an AppendOnlyArrayBackedMutableTable with the given initial data.

Parameters:

initialTable - the initial values to copy into the AppendOnlyArrayBackedMutableTable

Returns:

an empty AppendOnlyArrayBackedMutableTable with the given definition

make

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

Create an AppendOnlyArrayBackedMutableTable with the given initial data.

Parameters:

initialTable - the initial values to copy into the AppendOnlyArrayBackedMutableTable

enumValues - a map of column names to enumeration values

Returns:

an empty AppendOnlyArrayBackedMutableTable with the given definition

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