Number of entries in set. This only accounts the actual valid entries. See [`n_tombstones`](Self::n_tombstones) for the tombstone count.

Return `self <= other`

Applies a function returning a [`ParseResult`] over the result of the `parser`. If the parser returns an error, the result will be mapped to an unreco

This is very similar to nom's `map_res`, but creates a `nom::Err::Failure` instead.

returns the namespace name, if known, used for logging

Returns a new execution context suitable for running queries

Get receiver for mocked operations. The data will be sent BEFORE barriers are passed and contains the original instance of the parameters, not the on

Calculate the offset in nanoseconds that needs to be added to a UTC timestamp in a timezone to get a local time value.

Set up initial user, org and bucket

Takes a record batch and returns a new record batch with dictionaries optimized to contain no duplicate or unreferenced values Where the input dictio

Try to get the type of the value stored in this column. # Errors This will return an error if: 1. There are no values in this column 2. The stored v

Persists a checkpoint to object store.

Compute projected schema.

Determine the output statistics, handling the [`chunk_order_field`] if missing. This will error for any other missing field, except for the chunk ord

Push a `T` that implements [`std::fmt::Display`] to the internally-stored string. This method will automatically add the `|` to separate the `T` from

returns a query, if know, used for logging

Parse a regular expression, delimited by `/`.

Registers `handle` as the IO runtime for this thread See [`spawn_io`]

If a metric with the provided `name` already exists, returns it Otherwise, invokes `options` and creates a new Metric from the returned options, stor

Replace the catalog with state loaded from a backup, coordinated across the cluster. Persists a [`RestoreCatalog`](crate::format::records::RestoreCat

Runs the expr using `run_plan` in the requested timezone and compares the result to `expected`

Execute a WAL plugin in dry-run mode for testing purposes. Runs the plugin with real queries but buffers all writes without persisting them. The buff

Schema is the same as the input schema

Send an HTTP request and return `Some(O)` if the response status is HTTP 201 Created.

This function translates data in DataFusion `MetricSets` into IOx [`Span`]s. It records a snapshot of the current state of the DataFusion metrics, so

Parse a `FROM` clause for various `SHOW` statements.

Entry point for show system commands

Invoke application shutdown This will signal backend shutdown and wake the [`wait_for_shutdown`][ShutdownToken::wait_for_shutdown] future so that reg

Build the renamed name for a soft-deleted resource as `{base}-{deletion_time}`. If that stamped name already exists (per `has_name_collision`), the re

Span new task on current runtime.

Runs `fut` on the runtime registered by [`register_io_runtime`] if any, otherwise awaits on the current thread # Panic Needs a IO runtime [registered

Converts PersistedSnapshot files into table-specific TableIndexSnapshot files. This method is part of the migration strategy from the old snapshot fo

Creates an execution plan for the SPLIT operations which does the following: 1. Merges chunks together into a single stream 2. Deduplicates via PK as

Plan a SQL statement. This assumes that any tables referenced in the SQL have been registered with this context. Use `create_physical_plan` to actuall

Get [statistics](FutureStats) for the contained future.

Responding with a stream of bytes, wrapping each frame in `Ok`. If you have a stream of `Result`s of `Bytes`, see [`stream_results_to_response_body`]

Get-or-create a table. Uses [`FieldFamilyMode::Aware`], no retention. Aware mode is the write-path default (matching v2): a `family::field` field nam

Get the tags that define this series.

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

Helper function to create a LogicalPlan with more columns for testing

Returns the time dimension for the `GROUP BY` clause.

to_nanos returns a timestamp in nanoseconds respecting the precision units. If a timestamp isn't provided, the default timestamp is used, and that va

Reserve `sz` bytes of memory. This will return an error if the amount of memory allocated will exceed the maximum if the allocation were to be allowed

Returns the union of this range with `other` with the minimum of the `min`s and the maximum of the `max`es

Parse an unquoted InfluxQL identifier.

Update a table in the database. This fails if the table doesn't exist.

Catch up by replaying log files up to and including `update_to`. Returns immediately if the local catalog is already at or past `update_to`. Stops whe

Push `batches`, a stream of [`RecordBatch`] instances, to object storage. Any buffering needed is registered with the pool provided by the [`RuntimeE

An iterator visiting all parameter values. Currently this will iterate in an arbitrary order, but specific ordering is subject to change and shouldn't

specify a header for jaeger_trace_context_header_name For example, 'uber-trace-id'

Sets whether or not an event’s target and location are displayed. Defaults to true. See [tracing_subscriber::fmt::Layer::with_target]