Get the nanosecond timestamp as an `i64`, before which, entries that have not been seen since are considered expired.

Extend this [`MutableBatch`] with `ranges` rows from `other`

Return the time range of the context, including any additional intervals required for window functions like `difference` or `moving_average`, when the

Extract all argument IDs from a Command recursively

Extract [`Vec<LexicalRanges>`] from plan, per partition, regardless of whether disjoint or not.

Make only the next call fail

Download release artifact/file.

Return the InfluxDB data model type, if any, and underlying arrow schema field for the column identified by `name`.

Check if a field has any InfluxQL-specific metadata that should be stripped before physical planning.

Parse the projection list of a `SELECT` statement. ```text field_list ::= field ( "," field ) ```

Maps an [`InfluxFieldType`] to a [`VarRefDataType`].

Returns an iterator of `&Field` for all the field columns of this schema, in order

Returns an iterator over the files in this snapshot

Given a [`MutableBatch`] a time predicate and a set of row ranges, returns the row indexes that pass the predicate # Panic Panics if `batch` does no

Search the provided `Expr`'s, and all of their nested `Expr`, for any that pass the provided test. The returned `Expr`'s are deduplicated and returned

Find the python installation location (not virtual env). XXX: use build flag?

Find the unique list of tables used by `s`, recursively following all `FROM` clauses and return the results in lexicographically in ascending order.

Find all the columns where the resolved data type is a tag or is [`None`], which is unknown.

Returns a set of batches like this: tag1, tag2, tag3, tag4, tag5, field1, field2

calculating the size for fixed length values, taking first batch size * number of batches This method is faster than .full_size(), however it is not s

Get an [`influxdb_iox_client::flight::Client`] for InfluxQL queries

allocate a new chunk with the right size, returning the currently built chunk if it has non zero length `self.current_chunk.len()` is zero

Run in a spawn blocking task to flush reports to the csv file

if sampled 1 else 0 is clearer than i32::from(sampled) imo

Take a series of sort_exprs, and convert to strings.

Format the retention period the way the v1 /query API reports retention durations, e.g. `168h0m0s`.

The total number of functions observed.

Returns the element with ID `id` found via binary search. Implemented by hand rather than calling `std::slice::binary_search_by` to avoid needing to a

returns the bounds for the earliest window bounds that contains the given time t. For underlapping windows that do not contain time t, the window dir

Handles `GetFlightInfo` RPC requests. The [`FlightDescriptor`] is treated containing an FlightSQL command, encoded as a binary ProtoBuf message. see

Get handle to IO runtime. # Panic Needs a IO runtime [registered](register_io_runtime).

Acquire a permit to write the provided `CatalogBatch` to object store This issues a `Prompt` to signal retry or success. The provided `sequence` is c

Extract the desired per-query configuration from the request metadata.

Return a map of all retention periods indexed by their combined database & table IDs.

Return the oldest allowable timestamp for the given table according to the currently-available set of retention policies.

Return the schema for the specified query

Get table batches from the buffer only This is meant to be used in tests.

Handles the return state from the plugin, writing back lines and handling any errors. It returns a vec of error messages that can be used to log or re

Handle the result of a trigger execution, returning the appropriate control flow action. This centralizes the error handling logic for WAL flush trig

Hard-delete a table, removing it from the catalog.

Consistently hash `key` to a `T`.

Get health of an instance

Histogram of record types over a set of records, sorted by id.

Return the http base URL for the HTTP API