Warm the checkpoint cache with a loaded checkpoint. This should be called during server startup after loading checkpoints from object store. Only pop

Print a warning message formatted like the logging system output.

Enable/disable ANSI encoding for formatted events (i.e. colors). Defaults to true if connected to a TTY, false otherwise. See [tracing_subscriber::fm

Set the expected output count

Set a host identifier prefix on the spawned [`TestServer`]

set the null percentage

Set the number of rows to generate

Set the number of distinct tag values

Add a `InfluxQlShowDatabases` to the handler This allows the implemention of `InfluxQlShowDatabases` to be added optionally so that systems that supp

Set the virtual env dir for this [`TestServer`]

Wraps an intermediate node (like [`FilterExec`]) that has a single input but also uses some columns itself into appropriate projections. This will tu

Cast from `i64` to `u64` but wrap negative numbers around.

This function is only called when running tests to get hold of the server port details as the tests start on arbitrary port by passing in 0 as port. T

Write the record batches in a columnar format.

ALMOST Functionally equivalent to calling [`Self::write_i64`] with an all-valid valid mask, but more performant when your values already exist in a sl

Write the u64 typed column identified by `name` For each set bit in `valid_mask` an a value from `values` is inserted at the corresponding index in t

Write the contents of a WAL file to the cache by iterating over its database and table batches to find entries that belong in the cache.

Write the contents from a wal file into the cache by iterating over its database and table batches to find entries that belong in the cache. Only if

Returns the database schema if it exists and is not deleted.

Add a test chunk to the database

Add the columns to this [`TableDefinition`] This ensures that the resulting schema has its columns ordered

Helper function to create a modified schema with different metadata

Add all the [`SequenceNumber`] in `other` to `self`. The result of this operation is the set union of both input sets.

Converts all field_predicates we have seen into a field column restriction on the predicate by evaluating the expressions at plan time Uses arrow eva

All records in the file, in write order.

Express this cache size in terms of bytes (B)

Map enum variant to static string, followed inverse of clap parsing rules.

for serialization as telemetry

Panics if the provided string matches [0-9a-z_]+

Assert: schema check failure for both single- and multi- threaded.

Wait for any in-flight background checkpoint to finish by acquiring the single permit; release it immediately so later assertions aren't blocked.

Background task that listens for catalog updates and maintains last value caches. This should be started explicitly after creating the provider.

Converts the [`RecordBatch`]es into a pretty printed output suitable for comparing in tests Example: ```text "+-----+------+------+-----------------

Broadcast a `CatalogUpdate` to all subscribed components in the system.

Construct the [`Connection`] instance using the specified base URL.

Create an Arrow array with gaps filled in between values using linear interpolation. This method has a template parameter and so accepts Arrow arrays

Builds a chunk with always-present (`tag1`, `fld`, time) columns; adds the variable column when `has_variable`. Parquet chunks get `with_dummy_parquet

Build an index of file IDs to their (db_id, table_id) location.

Get all built-in specs

Determine the possible maximum range for each of the fields in a ['ArrowSchema'] once the ['Expr'] has been applied. The returned Vec includes an Inte

Get the total count of unique value combinations nested under this node Note that this includes expired elements, which still contribute to the total

Validate the arguments for the `distinct` function call.

Create a new child span with the specified name Note that the created Span will not be emitted automatically. The caller must explicitly call [`Self: