Send slice.

Register metric instrumentation for given tokio runtime. # Lifecycle When the [`Runtime`] linked to the given metrics is shut down, the metrics will

Parse a `SHOW TAG KEYS` statement, starting from the `KEYS` token.

Create a [`DynError`] from a string. The contained error can be [cast down] to [`StringError`]. Note: Linking to `dyn Error` doesn't really work vi

Create a test cached object store with a cache capacity of 1GB

Update given base statistics with the given schema. This only updates columns that were present when the aggregator was created. Column reordering is

Parse a variable reference, which is a segmented identifier followed by an optional cast expression.

Returns the result of `f` if it satisfies `is_valid`; otherwise, returns an error using the specified `message`.

Sets field_column restriction

Appends `count` set bits

Build a datafusion [`LexOrdering`] from an iox [`SortKey`].

the short string description of the type

Average function that returns average based on the type provided. u64 for example will return avg as u64. This probably is fine as we don't really nee

Build a catalog over a fresh in-memory store and return it together with the store so tests can stage backup images directly.

Return a new conditional expression, `lhs op rhs`.

Build and persist checkpoints from loaded snapshots. Processes one month at a time: groups snapshots by month, builds checkpoint for the oldest month

build DF statistics for given chunks and a schema

Check if the catalog checkpoint file is present in this store, which would indicate that the catalog has been initialized, and is used to check if the

Returns true if this range contains the value v

Create chunk [statistics](Statistics).

Writes a `&str` value to `f`, escaping all characters in `escaping_specificiation`. Use the constants defined in this module.

Fetch the value from an object store

Add a new nullable field column with the specified Arrow datatype.

Parser for a single field and value ```text field_and_value := qualified_field "=" value qualified_field := field_family? identifier field_family :

Map the InfluxQL `SELECT` projection list into a list of DataFusion expressions.

Returns the file at index `idx`

Extract the full table ID (node_id, db_id, table_id) from the path. This method will panic if called on a path not created by `TableIndexPath::new`,

Retrieve the given value from the remote cache, if present Returns [`Error::NotModified`] if value exists and matches `generation`

Increments the window function call count

Returns an iterator over set bit positions in increasing order

Parse an InfluxQL literal, except a [`Regex`]. Use [`literal`] for parsing any literals, excluding regular expressions.

Parses a field name from a string. ```text qualified_field := field_family? identifier field_family := identifier "::" ```

Adds [`InfluxQlMetadata`] to the `plan`.

Takes in a datasource schema and statistics, and projects the scan schema on top. This handles use cases where we may be either: (1) scanning a subse

Given a `Vec` of pruning summaries, return a `Vec<bool>` where `false` indicates that the predicate can be proven to evaluate to `false` for every sin

Push a new element into the [`CacheColumn`]

Record that an object store operation failed at `at` with the given category. Writes atomically -- readers never observe a new timestamp with an old c

Recursively rewrite the specified [`SelectStatement`] by performing a series of passes to validate and normalize the statement.

Sets the classification of this request if not already set

Set meta data.

Create a database + table with a tag and field column for cache tests.

Sets up a database with a trigger and its channel for deletion tests. Creates a "test_db" database, registers a trigger of the given kind in the cata

Parse a `SHOW FIELD KEYS` statement, starting from the `FIELD` token.

Meaningful progress was made.

Soft-delete a database. The database is renamed in place (so the original name can be re-used) and scheduled for hard deletion at the resolved time.

Create a SendableRecordBatchStream a RecordBatch

Returns the remaining elements after [Self::head].

In production code, the template should come from protobuf that is either from the database or from a gRPC request. In tests, building protobuf is pai

Transform the schema of a single [`LogicalPlan`] node by applying a function to its schema. This function is a wrapper around [`datafusion_util::tran