Plan "Aggregate" SELECT queries. These are queries that use one or more aggregate (but not window) functions.

Apply a projection to the input plan to ensure that the time column is in the correct timezone.

projection with 2 constant integers, one as an literal integer and the other is converted to string and used as a dictionary value. These are done on

projection with 3 dictionnary constants and an normal column

If neither a v3 nor a v2 catalog exists at `cluster_id` but a v2 catalog exists at `current_node_id` (i.e. this binary previously ran as a core node),

Prune nodes from within the cache This first prunes entries that are older than the `max_age` of the cache. If the cardinality of the cache is still

Correctly typed pointer.

Purge expired parquet files from a table based on retention cutoff time. This method selectively deletes only files where max_time < cutoff_time_ns.

Get the [`QueryReporter`] along with the path of the file it is generating as a `String`

Get Query Suggestions

Query Suggestions with name

Reads the plugin entry point (`__init__.py`) if any Python file in the directory has been modified.

Fetch and parse a file at the given object path.

Rebuild the Arrow `schema` from the current column set.

Recalculate min_time and max_time by scanning all files.

Reduce `duration OP expr`. ```text duration = duration ( ADD | SUB ) ( duration | NOW() ) duration = duration ( MUL | DIV ) ( float | integer ) tim

Reduce `float OP expr`. ```text float = float ( ADD | SUB | MUL | DIV | MOD ) ( float | integer) ```

Return a `ReduceContext` with a value of now set to `2023-01-01T00:00:00Z` / `1672531200000000000` and not timezone.

Folds `expr` and `remainder` into a [Expr::Binary] tree.

Return an Expr that invokes a InfluxRPC compatible regex match to determine which values satisfy the pattern. Equivalent to: ```text col ~= /pattern/

Given a column containing string values and a single regex pattern, `regex_match_expr` determines which values satisfy the pattern and which do not.

Return an Expr that invokes a InfluxRPC compatible regex match to determine which values do not satisfy the pattern. Equivalent to: ```text col !~ /p

[Registers](register_io_runtime) current runtime as IO runtime. This is mostly a convenience function for testing.

Register where the parquet object was found.

Return an [`FunctionRegistry`] with the implementations of IOx UDFs only

remap the column references in the expression to the new indices specified in the map.

Remove all elements before the given nanosecond timestamp returning `true` if the resulting node is empty.

Replace an entire plugin directory atomically with new files.

Validate that `db_name` resolves to a non-soft-deleted database.

Makes as detailed error message as possible

A response generator that validates URIs and delegates to an inner store.

Reload the catalog from the selected object-store checkpoint and log files, then coordinate the restore through a sequenced catalog log entry. Applyin

Retry errors caller says are retriable

Perform an async operation that retries caller specified errors, with a backoff

Perform an async operation that retries with a backoff

Perform a series of passes to rewrite `expr`, used as a column projection, to match the behavior of InfluxQL.

Generic function to calculate min/max/avg from another set of stats. This function works for all types of numbers (unsigned/signed/floats). It calcula

round robin repartition into the specified number of partitions

Run a plan against the following input table as "t"

Three records — register-node, create-database, create-table — used to populate the hand-built snapshot fixtures.

Re-scopes this error as the child of another field

Build a catalog seeded with two nodes and three databases. `beta` is soft-deleted with a hard-delete time of t=2000 — note that soft-delete renames th

Generate a plan to select the first n rows from each partition in the input data, optionally sorted by the requested field.

Send an HTTP request and return `O` on success.