Set up a new user, org and bucket

Preserve partitioning from plan inputs. Apply fetch variables (fetch/skip) to modify the [`Statistics::num_rows`]. This does not perform any schema p

Process removed files from a snapshot. Files found in the index are removed from the checkpoint. Files not found are added to pending_removed_files.

Remove all traces of the specified database from the cache and object store for the current node.

Push new entry back to the set. # Panic The entry MUST NOT be part of the set yet. # Runtime Complexity This is always `O(1)`.

Size-gated PUT using [`DEFAULT_MULTIPART_CHUNK_SIZE`].

return a reference to the query

Query and return the raw string data from the server

Takes an iterator of [`Option`] and merges identical consecutive elements together. Any [`None`] yielded by `iterator` is added to the range for the

Parse the request's body into raw bytes, applying the configured size limits and decoding any content encoding.

Read IOx metadata from file-level key-value parquet metadata.

Read IOx schema from parquet metadata.

Read IOx statistics (including timestamp range) from parquet metadata.

Take a series of sort_exprs, and remap the projections.

Update the health handle based on a single operation's outcome. Shared between per-call observation and per-stream-item observation so the NotFound-as

Record that an object store operation succeeded at `at`. Overwrites any previously recorded success timestamp. Does not clear prior error state; [`las

Reduce `timestamp OP expr`. The right-hand `expr` must be of a type that can be coalesced to a duration, which includes a `duration`, `integer` or a

Folds `expr` and `remainder` into a [ConditionalExpression::Binary] tree.

Simplify the time range expression and return a literal [timestamp](Timestamp).

Walk a freshly-created catalog through the full Register -> RequestStop -> AckStop sequence so the node ends up in the terminal `Stopped` state.

Walk a freshly-created catalog to the `Stopping` state via RegisterNode + RequestStopNode.

Register node id=1 name="node-a", then drive it into the `Stopping` state via `RequestStopNode`. Returns the catalog ready for AckStopNode tests.

Remove files that are marked for deletion or that violate their retention period.

Run `DeduplicateExec` on the input data

Runs the provided future using this execution context

Produce the Arrow schema for the `SHOW DATABASES` InfluxQL query

Seed a per-trigger (local) Python cache entry for `(db_id, trigger_id)`. Requires `init_pyo3()` to have run.

Returns a Schema for the given (sub)set of column projects

Set the [AggrColState] for this cursor. `self` will have been created via `Cursor::clone_for_aggr_col`, so [Cursor::aggr_col_states] will contain exac

Set all generation durations (including gen1) in a single atomic operation. # Arguments `durations` - Array of durations where index 0 is gen1, index

Sets new state and call [`emit`](Self::emit).

Set the generation-1 compaction duration. # Legacy Note This is method is for the legacy Parquet storage engined setting.

Forward-only storage-mode transition: `Parquet → ParquetAndPachaTree → PachaTree`. Other transitions are rejected as Internal errors. Re-issuing the c

Setup write buffer with checkpointing enabled for integration tests. Returns the write buffer, context, time provider (for time control), and the pers

Parse a `SHOW MEASUREMENTS` statement after `SHOW` and any whitespace has been consumed.

create a `Vec<PhysicalSortExpr>` from the specified columns for the current node

return all collected spans

Split this SeriesChunk into two SeriesChunks at the given size.

Parse a terminator that ends a SQL statement.

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

Returns an iterator of all the names of the tag dimensions for the `GROUP BY` clause.

Helper function to create a simple LogicalPlan for testing

Helper function to create a simple test schema

Test: perform and assert upload of metadata

Convert a query log entry state into the InfluxDB line protocol format.

Truncate a string for logging untrusted input to prevent log flooding

Attempts to insert the given name-value pair, using [`StatementParam::try_from`] on the given value prior to inserting into the map. If the [`Stateme

Two `Catalog` instances backed by the same underlying `InMemory` object store, simulating two writers racing on the same persistent catalog.

Union two [`LogicalPlan`]s, and type-coerce inputs. The InfluxQL planner uses the type-coerced UNION plans when constructing the rest of the logical

Extract a counter typed value. # Panics Panics if the value is not a counter.

Returns the validity bitmask of this column

Validates that the packed strings array is valid

Future that completes when [`ShutdownManager`] that issued this token is shutdown