Package com.illumon.iris.db.v2
Class NestedPartitionedDiskBackedTable
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.UncoalescedTable
com.illumon.iris.db.v2.RedefinableTable
com.illumon.iris.db.v2.SourceTable
com.illumon.iris.db.v2.PartitionAwareSourceTable
com.illumon.iris.db.v2.NestedPartitionedDiskBackedTable
- All Implemented Interfaces:
com.fishlib.base.log.LogOutputAppendable,NotificationQueue.Dependency,Deflatable<Table>,Table,LivenessManager,LivenessNode,LivenessReferent,LongSizedDataStructure,DynamicNode,DynamicTable,NotificationStepReceiver,NotificationStepSource,SystemicObject,Serializable
public class NestedPartitionedDiskBackedTable extends PartitionAwareSourceTable
Partition-aware source table with support for a single internal partition and a single column partition.
- See Also:
- Serialized Form
-
Nested Class Summary
Nested classes/interfaces inherited from class com.illumon.iris.db.v2.SourceTable
SourceTable.QueryTableReferenceNested 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 inherited from class com.illumon.iris.db.v2.PartitionAwareSourceTable
ALL_INTERNAL_PARTITIONSFields inherited from class com.illumon.iris.db.v2.BaseTable
attributes, definition, description, PRINT_SERIALIZED_UPDATE_OVERLAPSFields inherited from interface com.illumon.iris.db.v2.NotificationStepReceiver
NULL_NOTIFICATION_STEPFields 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 -
Constructor Summary
Constructors Constructor Description NestedPartitionedDiskBackedTable(TableDefinition tableDefinition, SourceTableComponentFactory componentFactory, TableLocationProvider locationProvider, LiveTableRegistrar liveTableRegistrar, Set<String> internalPartitions) -
Method Summary
Modifier and Type Method Description voiddropReference()Drop a previously-retained reference to this referent.WeakReference<? extends LivenessReferent>getWeakReference()Get aWeakReferenceto this referent.voidinitializeTransientFieldsForLiveness()Package-private forSerializablesub-classes to use inreadObjectonly.protected NestedPartitionedDiskBackedTablenewInstance(TableDefinition tableDefinition, String description, SourceTableComponentFactory componentFactory, TableLocationProvider locationProvider, LiveTableRegistrar liveTableRegistrar, Set<String> internalPartitions, com.illumon.dataobjects.ColumnDefinition<String> partitioningColumnDefinition, SelectFilter... partitioningColumnFilters)protected voidonReferenceCountAtZero()Callback method that will be invoked when the reference count returns to zero.booleantryManage(LivenessReferent referent)Attempt to add the specified referent to this manager.booleantryRetainReference()If this referent is "live", behave asLivenessReferent.retainReference()and return true.Methods inherited from class com.illumon.iris.db.v2.PartitionAwareSourceTable
filterLocations, redefine, redefine, selectDistinct, whereMethods inherited from class com.illumon.iris.db.v2.SourceTable
destroy, doCoalesce, initializeAvailableLocations, refreshMethods inherited from class com.illumon.iris.db.v2.RedefinableTable
dropColumns, renameColumns, updateView, viewMethods inherited from class com.illumon.iris.db.v2.UncoalescedTable
absSumBy, addColumnGrouping, aj, applyToAllBy, avgBy, by, byExternal, coalesce, countBy, exactJoin, firstBy, flatten, getCoalesced, getColumn, getColumnSource, getColumnSourceMap, getColumnSources, getIndex, getRecord, getSubTable, head, headBy, headPct, isFlat, join, lastBy, lazyUpdate, leftJoin, listenForDirectUpdates, listenForUpdates, listenForUpdates, listenForUpdates, listenForUpdatesUncoalesced, maxBy, medianBy, minBy, naturalJoin, preemptiveSnapshotTable, preemptiveUpdatesTable, raj, removeDirectUpdateListener, removeUpdateListener, removeUpdateListener, removeUpdateListenerUncoalesced, reverse, rollup, select, setCoalesced, silent, size, sizeForInstrumentation, slice, snapshot, snapshotHistory, snapshotIncremental, sort, stdBy, sumBy, tail, tailBy, tailPct, treeTable, ungroup, update, updateBy, validateSelect, varBy, wavgBy, whereIn, wouldMatch, wsumByMethods inherited from class com.illumon.iris.db.v2.BaseTable
addParentReference, append, awaitUpdate, awaitUpdate, clearSortingRestrictions, copy, copyAttributes, copyAttributes, createSwapListenerIfRefreshing, getAttribute, getAttributeNames, getAttributes, getDefinition, getDescription, getLastNotificationStep, getNotificationQueue, hasAttribute, initializeWithSnapshot, isAddOnly, isAddOnly, isFailed, isRefreshing, isSystemicObject, layoutHints, markSystemic, notifyListeners, notifyListenersOnError, restrictSortTo, satisfied, setAttribute, setColumnRenderers, setLastNotificationStep, setRefreshing, setTotalsTable, shouldCopyAttribute, toString, withColumnDescription, withKeys, withTableDescription, withUniqueKeysMethods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact
manageWithCurrentScope, unmanage, unmanageMethods inherited from class com.illumon.util.referencecounting.ReferenceCounted
decrementReferenceCount, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCountMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.illumon.iris.db.v2.DynamicTable
newModifiedColumnSet, newModifiedColumnSetIdentityTransformer, newModifiedColumnSetIdentityTransformer, newModifiedColumnSetTransformer, newModifiedColumnSetTransformer, newModifiedColumnSetTransformer, notifyListenersMethods inherited from interface com.illumon.iris.db.util.liveness.LivenessManager
manage, tryManageMethods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent
dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReferenceMethods inherited from interface com.illumon.iris.db.tables.Table
absSumBy, absSumBy, absSumBy, aj, aj, aj, aj, aj, apply, applyToAllBy, applyToAllBy, applyToAllBy, avgBy, avgBy, avgBy, by, by, by, by, by, by, byExternal, byteColumnIterator, characterColumnIterator, clearSortingRestrictions, close, columnIterator, countBy, countBy, countBy, dateTimeColumnAsNanos, dateTimeColumnAsNanos, deflate, deflate, doubleColumnIterator, dropColumnFormats, dropColumns, exactJoin, exactJoin, exactJoin, exactJoin, firstBy, firstBy, firstBy, floatColumnIterator, formatColumns, formatColumnWhere, formatRowWhere, getAttribute, getAttributeNames, getAttributes, getAttributes, getColumn, getColumns, getColumnSource, getDefinition, getDescription, getMeta, getViewPort, hasAttribute, hasColumns, hasColumns, headBy, headBy, integerColumnIterator, isEmpty, isLive, join, join, join, join, join, join, join, join, join, lastBy, lastBy, lastBy, layoutHints, 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, releaseCachedResources, renameAllColumns, renameColumns, renameColumns, restrictSortTo, rollup, rollup, rollup, rollup, rollup, rollup, rollup, select, select, select, selectDistinct, selectDistinct, selectDistinct, setAttribute, setColumnRenderers, setTotalsTable, shortColumnIterator, 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, withColumnDescription, withKeys, withTableDescription, withUniqueKeys, wouldMatch, wsumBy, wsumBy, wsumBy
-
Constructor Details
-
NestedPartitionedDiskBackedTable
@VisibleForTesting public NestedPartitionedDiskBackedTable(TableDefinition tableDefinition, SourceTableComponentFactory componentFactory, TableLocationProvider locationProvider, LiveTableRegistrar liveTableRegistrar, Set<String> internalPartitions)- Parameters:
tableDefinition- A TableDefinition (ust have storageType == STORAGETYPE_NESTEDPARTITIONEDONDISK)componentFactory- A component factory for creating column source managerslocationProvider- A TableLocationProvider, for use in discovering the locations that compose this tableliveTableRegistrar- Callback for registering live tables for refreshes, null if this table is not liveinternalPartitions- Allowed internal partitions - use ALL_INTERNAL_PARTITIONS (or an empty set) for no restrictions
-
-
Method Details
-
newInstance
protected NestedPartitionedDiskBackedTable newInstance(TableDefinition tableDefinition, String description, SourceTableComponentFactory componentFactory, TableLocationProvider locationProvider, LiveTableRegistrar liveTableRegistrar, Set<String> internalPartitions, com.illumon.dataobjects.ColumnDefinition<String> partitioningColumnDefinition, SelectFilter... partitioningColumnFilters)- Overrides:
newInstancein classPartitionAwareSourceTable
-
initializeTransientFieldsForLiveness
Package-private forSerializablesub-classes to use inreadObjectonly. 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:LivenessReferentIf this referent is "live", behave asLivenessReferent.retainReference()and return true. Otherwise, returns false rather than throwing an exception.- Specified by:
tryRetainReferencein interfaceLivenessReferent- Returns:
- True if this referent was retained, false otherwise
-
dropReference
public final void dropReference()Description copied from interface:LivenessReferentDrop a previously-retained reference to this referent.- Specified by:
dropReferencein interfaceLivenessReferent
-
getWeakReference
Description copied from interface:LivenessReferentGet aWeakReferenceto this referent. This may be cached, or newly created.- Specified by:
getWeakReferencein interfaceLivenessReferent- Returns:
- A new or cached reference to this referent
-
tryManage
Description copied from interface:LivenessManagerAttempt to add the specified referent to this manager.- Specified by:
tryManagein interfaceLivenessManager- Parameters:
referent- The referent to add- Returns:
- Whether the referent was in fact added
-
onReferenceCountAtZero
protected final void onReferenceCountAtZero()Description copied from class:ReferenceCountedCallback method that will be invoked when the reference count returns to zero.- Specified by:
onReferenceCountAtZeroin classReferenceCounted
-