Create statistics for a column with zero nulls and unknown distinct count

MIRI cannot handle this

Create a new [`InfluxRpcPredicate`] for the given table

TESTING ONLY:** Create new ID from integer. Since this can easily lead to ID collisions (which in turn can lead to panics), this must only be used fo

Get testing executor that runs a on single thread and a low memory bound to preserve resources.

Create new executor for testing purposes. Internal state may be shared with other tests.

Create a [`ShutdownManager`] for testing purposes This handles creation of the frontend [`CancellationToken`] for tests where `tokio-util` is not a d

Get testing executor that runs a on single thread and a low memory bound to preserve resources (central memory pool) and a per query memory pool.

Create a YearMonth from year and month without validation. # Safety Use only when the values are known to be valid (e.g., from chrono). In debug buil

Create metrics that are not associated with any registry.

Create a new unregistered `RecorderCollection` with the default options

Gets a new unregistered recorder

Create a new unregistered `RecorderCollection` from the provided options

Initialize a new [`TableSchema`] with the given id, no columns, default partition, and iceberg disabled.

Like `new` but appending to an existing `BufMut`.

Construct `Catalog` with [`CatalogArgs`] and [`CatalogLimits`].

Create a new `Catalog` with the specified checkpoint interval # Note This is intended for testing purposes.

Create a [`Writer`] for inserting `to_insert` rows into the provided `batch`, accepting new columns only on passing checks from the [`ColumnInsertVali

Low-level constructor. This is mostly useful if you wanna keep the executor (because they are quite expensive to create) but need a fresh IOx runtime

Creates a new batched write client with default configuration.

Create new stream based on an existing stream that transports [`Result`]s w/ [`DataFusionError`]s. Also receives an executor that actually executes t

Create new statistics with the specified count and null count and distinct values

Create new stream based on an existing stream that transports [`Result`]s. Also receives an executor that actually executes the underlying stream as

Creates a new client with the provided request maker

Configure this panic handler to emit a panic count metric. The metric is named `thread_panic_count_total` and is incremented each time the panic hand

Same as [`new`](Self::new), but with an optional collector.

Creates a new `Backoff` with the optional `rng`. Used [`rand::thread_rng()`] if no rng provided. See [`new`](Self::new) for panic handling.

Create new stream with provided schema.

Construct `Catalog` and initiate a background task that flips the registered node to `Stopped` when `shutdown_token` is cancelled.

Create new `Catalog` that uses the specified `ObjectStore`. # Note This is intended as a convenience constructor for testing

Create new stream by producing a future that sends its state to the given [`Sender`]. This is an internal method. `f` should always be wrapped into [

Creates a new [`ReloadableTokenRequestMaker`] without any token. This is useful when no authentication is configured.