Package io.deephaven.engine.table.impl.util
package io.deephaven.engine.table.impl.util
-
ClassDescriptionAn in-memory table that allows you to add rows as if it were an InputTable, which can be updated on the UGP.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.This is a structured object that represents the barrage update record batch.ColumnHolder<T>Data to construct a data column.Convert value columns into labeled rows.Re-usable tool for scheduling delayed error notifications to be enqueued on the next update graph cycle.The DynamicTableWriter creates an in-memory table using ArrayBackedColumnSources of the type specified in the constructor.Utilities for manipulating object fields.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 GroupedWritableRowRedirection is intended for situations where you have several row sets that represent contiguous rows of your output table and a flat output RowSet.An abstract table that represents a hash set of array-backed tuples.An interface for submitting jobs to be executed.JobScheduler.IterateAction<CONTEXT_TYPE extends JobScheduler.JobThreadContext>Helper interface for
iterateSerial()anditerateParallel().JobScheduler.IterateResumeAction<CONTEXT_TYPE extends JobScheduler.JobThreadContext>Helper interface forJobScheduler.iterateSerial(io.deephaven.engine.context.ExecutionContext, io.deephaven.base.log.LogOutputAppendable, java.util.function.Supplier<CONTEXT_TYPE>, int, int, io.deephaven.engine.table.impl.util.JobScheduler.IterateResumeAction<CONTEXT_TYPE>, java.lang.Runnable, java.util.function.Consumer<java.lang.Exception>)andJobScheduler.iterateParallel(io.deephaven.engine.context.ExecutionContext, io.deephaven.base.log.LogOutputAppendable, java.util.function.Supplier<CONTEXT_TYPE>, int, int, io.deephaven.engine.table.impl.util.JobScheduler.IterateAction<CONTEXT_TYPE>, java.lang.Runnable, java.util.function.Consumer<java.lang.Exception>).JobScheduler.IterationManager<CONTEXT_TYPE extends JobScheduler.JobThreadContext>A default context for the scheduled job actions.An in-memory table that has keys for each row, which can be updated on the UGP.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.GeneralizesPerformanceQueriesto accept table parameters and make evaluation number parameter optional.Data structure for mapping one "outer" row key space to another "inner" row key space.Convertstable updatesused forstandard table update listeners's intorow setscompatible with legacy-styleshift-oblivious listenersby expanding keyspace shifts.Cache memory utilization.Helper utility for inverting row key shifts.Helper utility for coalescing multipleupdates.RowRedirectionthat redirects all outer row keys to the same inner row key.SizedSafeCloseable<T extends SafeCloseable>Tool for maintaining recorded clock steps.Return the rows with the highest commonly available ID from multiple tables.Produce a map of synchronized tables, keyed by the name assigned to each input table.Deprecated.Accessors for Deephaven tables of instrumentation logs.This class contains static methods to support conversions between various time types such asInstant,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.Static functions used by Typed Hashers.Helper utility for coalescing multipleupdates.Calculate the size of the chunks needed to process an update.WritableRowRedirection.Factory for producing WritableRowRedirections and their components.This is a lock-free implementation of a WritableRowRedirection.