Package com.illumon.iris.db.v2.utils
package com.illumon.iris.db.v2.utils
-
ClassDescriptionThis is the base class for factories that construct
Indexes.Common base class for index update notifications.Common base class for notifications.An in-memory table that allows you to add rows as if it were an InputTable, which can be updated on the LTM.The ArrayBackedTableWriter creates an in-memory table using ArrayBackedColumnSources of the type specified in the constructor.When we get an error from a table in the listener tree, we want to send an appropriate command to the clients indicating that something has gone wrong with the table.A static implementation for simple, ephemeral, error recording within a single query.Convert an arbitrary chunk to a chunk of boxed objects.Return a chunk that contains boxed Objects representing the primitive values in primitives.Adapter to allow a Clock to serve as a TimeProvider.Data to construct a data column.Convert value columns into labeled rows.An iterator for the complement set over an universe of [0, Long.MAX_VALUE].Utilities for cumulative and rolling aggregations.Provides a helper class with a map to cache previous row values when performing filtering of data whose values change from row to row.Provides a helper class with a map to cache previous row values when performing rolling or cumulative aggregations.DynamicTableToAdoConverter<T extends com.fishlib.dataobjects.WAbstractDataObject>Convert DynamicTable changes into ADO handler calls.DynamicTableToAdoConverter.AdoHandler<T extends com.fishlib.dataobjects.WAbstractDataObject>The DynamicTableWriter creates an in-memory table using ArrayBackedColumnSources of the type specified in the constructor.Utility methods used for writing/readingIndexes.A TableMap that filters and optionally transforms the keys of another TableMap.FreezeBy records the first value for a given key in the output table and ignores subsequent changes.An abstract table that represents the result of a function.The GroupedRedirectionIndex is intended for situations where you have several Indices that represent contiguous rows of your output table and a flat output index.An abstract table that represents a hashset of smart keys.TableWriter that writes to multiple other writers.A set of sorted long keys between 0 and Long.MAX_VALUEA class for creatingIndexs in various ways.AnIndexBuilderthat accepts key additions in any random order.An builder forIndexs that requires keys to be added in a monotonically increasing fashion.A builder that constructs anIndexfrom a set of keys.A codec to encode and decode generic Indexes to a column.A set of sorted shifts.Helper utility to build instances ofIndexShiftDatawith internally consistent data.Helper utility to build instances ofIndexShiftDatawith internally consistent data.ExpandsShiftAwareListener.onUpdate(ShiftAwareListener.Update)'s Update into a backward compatible ARM (added, removed, modified) by expanding keyspace shifts.An in-memory table that has keys for each row, which can be updated on the LTM.Return rows from multiple follower tables with the IDs indicated by the leader table.Produce a Map of synchronized tables.Produce a Map of synchronized TableMaps.Note this is similar to java.util.function.LongPredicate; we don't use that since it could create confusion as for intended semantics for use.Utility to take a set of tables, each of which is sorted; and merge them together into a single table, which will also be sorted.An ordered collection of long keys.Iterator for consuming anOrderedKeysby ordered subsets.Some operations can pre-compute the necessary key-space needed to correctly maintain the intended result.A RandomBuilder type that uses a priority queue of ranges.Read-only subset of theIndexinterface.A RedirectionIndex can be in one of two states: tracking prev values or not.This is a lock-free implementation of a RedirectionIndex.This class enables a pattern of use where objects can be shared from multiple references/identities while they are used read-only.A row-oriented version of ArrayBackedTableWriter.Cache memory utilization.SizedSafeCloseable<T extends SafeCloseable>Return the rows with the highest commonly available ID from multiple tables.Produce a TableMap of synchronized tables.Class to aid in building Tables from a TableDefinition.This class contains static methods to support conversions between various time types such asDBDateTime,Instant,ZonedDateTime,LocalDate,LocalTime, andlong.For an Intraday restart, we often know that all data of interest must take place within a fixed period of time.Interface for providing the current time.This tool is meant to track periodic update events that take place in a LiveTableMonitor.Entry class for tracking the performance characteristics of a single recurring update event.Holder for logging details that are the same across the UpdatePerformanceTracker instanceHolder for logging details that are the same for every Entry in an intervalA smaller entry that simply records usage data, meant for aggregating into the larger entry.Calculate the size of the chunks needed to process an update.ThisRedirectionIndeximplementation flattens the view onto the underlying wrapped index.An operation that "Zips" a set of tables of together row by row, joining the columns together.A Builder to zip the columns of two tables together.