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.Helper interface for
iterateParallel().Helper interface for
JobScheduler.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>)and
JobScheduler.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>).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.Generalizes
PerformanceQueriesto accept table parameters and make evaluation number parameter optional.Data structure for mapping one "outer" row key space to another "inner" row key space.Cache memory utilization.Helper utility for inverting row key shifts.
RowRedirectionthat redirects all outer row keys to the same inner row key.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.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.Calculate the size of the chunks needed to process an update.Writable
RowRedirection.Factory for producing WritableRowRedirections and their components.This is a lock-free implementation of a WritableRowRedirection.