Insert columns into the in-memory lookup maps (`columns`, `tag_columns`, `field_families`, series key, sort key) # Note This does not rebuild the Ar

Add the specified header with value to all subsequent requests

Add all files from a persisted snapshot to the tracked files. Deduplicates against existing files. Called from `Replica::reload_snapshots` during re

Adds the specified schema and optionally a column summary containing optional stats. If `add_column_summary` is false, `stats` is ignored. If `add_col

Add files from a snapshot to the checkpoint, updating metrics and index.

Verifies _and_ applies the `CatalogBatch` to the catalog.

Apply an `OrderedCatalogBatch` to this catalog # Implementation note This accepts a `_permit`, which is not used, and is just a way to ensure that t

Returns `None` if the scope is `DataAndCatalog`, otherwise `Some(scope)`.

Return the protobuf representation of this template.

Return the value as a timestamp, if it is one.

Assert that given future is pending. This will try to poll the future a bit to ensure that it is not stuck in tokios task preemption.

Assert: roundtrip using existing store, based upon [`UploadType`]

Constructs the data point

Returns a [`Layer`] that emits logs as specified by the configuration of `self`.

Build a gap-filled array that takes from input_aggr_array and fills with `val` wherever `input_aggr_array` does not have a value. Assumes that `val` h

Generate [`Field`] for [chunk order column](CHUNK_ORDER_COLUMN_NAME).

Removes all `/` patterns that the rust regex library would reject and rewrites them to their unescaped form. For example, `\:` is rewritten to `:` as

TODO(trevor): remove thid API in favour of the Repository APIs

Returns underlying config.

Returns the number of set bits in this bitmap.

Create or regenerate the cluster's default operator (`_admin`) token. Returns the `TokenInfo` plus the raw token string. `regenerate=true` requires a

Create a ParquetFile with unique path and varying min_time. # Parameters - `idx`: Index used for unique path and time offset - `prefix`: Prefix for u

Create a PersistedSnapshot with files distributed across multiple dbs/tables. Files are distributed using modulo arithmetic: - db_id = file_index % N

Create a table with the provided options.

Create a resource-scoped token with caller-supplied hash and a list of permission specs.

Create a single `DataSourceExec`, with multiple parquet, with a given ordering and using the statistics from the [`SortKeyRange`]. Assumes a single co

Converts a [`DataFusionError`] into the appropriate [`tonic::Code`] Where possible, this function should try to ensure that the "user sees the error

Decode the next [`ListEntry`] from `buf` Call with an empty `buf` to indicate the end of the stream

Creates an `ScalarValue` that represents a Dictionary encoded string (e.g the type of constant that a tag would be compared to)

Return a single sample run from the generator as a string.

Convert a [`MutableBatch`] to [`TableBatch`]

Build the exprs and fields needed to create a `PartitionEvaluatorArgs` for `DerivativeUDWF`. If `interval` is `Some`, a third argument is included for

Extensions used by the store.

Extract chunks, schema, and output sort key from plans created with [`chunks_to_physical_nodes`]. Returns `None` if no chunks (or an [`EmptyExec`] in

Extract size hint from [`GetOptions`]. Returns the options with the potential size information stripped and the extracted size -- if there was a hint

Sets a field, replacing any existing field of the same name.

Fill buffer with pattern `0xff` without advancing the "initialized" position so we can check certain behavior.

Finds the latest modification time of any `.py` file in the plugin directory.

Consume this [`NullMaskBuilder`] and return the constructed null mask bitmap. This call is always `O(1)`. NOTE: this may have length of 0 if no NULL

Explicitly flush all pending writes. This method blocks until all currently buffered writes have been sent.

Get column name out of the `expr`. TODO use schema::SortKey instead.

Retrieve the authorization token associated with the request.

Helper: build a fresh handler for `extract_query_request` tests. These tests do not exercise execution, so the database / authz implementations are in

Map the `ColumnIdentifier`s to `ColumnId`s

Increments the aggregate function call count

Returns the [`InfluxColumnType`] of this column

returns the column name for a column expression

Check if the transaction is empty, meaning it has no pending operations.

Validate that a key (tag or field) is valid. Keys cannot be empty and cannot contain control characters (ASCII 0x00-0x1F and 0x7F). This ensures compa

Key.