Return min and max for column `time` in the given record batch by performing an `O(n)` scan of `batch`.

Compute the SHA512 hash of a token string This is the canonical way to hash tokens across the codebase

Converts a potentially truncated null mask to a valid mask

Resolve the data types of any [`VarRef`] expressions in the `WHERE` condition.

Parse conditional operators.

Parse the conditional regular expression operators `=~` and `!~`.

Create a new distinct value cache given the [`DistinctCacheCreateRequest`] arguments in the request body. If the result is to create a cache that alr

Delete a distinct value cache entry with the given [`DistinctCacheDeleteRequest`] parameters The parameters must be passed in either the query string

Create a new last value cache given the [`LastCacheCreateRequest`] arguments in the request body.

Delete a last cache entry with the given [`LastCacheDeleteRequest`] parameters This will first attempt to parse the parameters from the URI query str

Parse conjunction operators, such as `AND`.

Set a timeout for only the connect phase of a `Client`.

Sets the maximum duration of time the client will wait for the IOx server to accept the TCP connection before aborting the request. Note this does no

Returns true if this range contains all representable timestamps except possibly MAX_NANO_TIME This is required for queries from InfluxQL, which are

Convert the given list of filter expressions to a map of [`ColumnId`] to [`Predicate`] The resulting map uses [`IndexMap`] to ensure consistent order

Convert the given list of filter expresions `filters` to a map of [`ColumnId`] to [`Predicate`] The resulting map is an [`IndexMap`] to ensure consis

Copy deprecated environment variable values to their new prefixed names. Processes all provided aliases. For each `(new_name, old_name)` pair: - If o

An implementation must return an array that indicates, for each summary associated with this pruning oracle, if to its knowledge `column` contains ONL

Helper to count checkpoints for a specific month

Count lines in a portion of line protocol data: number of `\n` bytes, plus one for any trailing partial line.

Counts the number of rows that will be produced for a series that ends (exclusively) at `series_end`, including rows that have a null timestamp, if an

If the job is running or competed, returns the total amount of CPU time spent executing futures

Create a new bucket in the organization specified by the 16-digit hexadecimal `org_id` and with the bucket name `bucket`.

Create a new entry in the distinct cache for a given database and parameters.

Create a new entry in the last cache for a given database and table, along with the given parameters. If a new cache is created, it will return its n

Generate certs for tests if they do not already exist. For the most part this is needed only in CI for fresh builds. Locally it'll generate them the f

Create a cache by looking up its definition in the catalog by id.

Create a gRPC trace layer for request monitoring and metrics

Idempotently create the `_internal` system database with the long-lived retention period that hosts catalog system tables.

Create an admin token with a specific name and hash

Create a named admin token using a caller-supplied hash.

Create minimal parquet file that triggers https://github.com/influxdata/EAR/issues/6643 Data layout: - Tag column - 3 tag values 'a', 'b', 'c' with ro

Create minimal parquet file that triggers https://github.com/influxdata/EAR/issues/6643 Data layout: - Tag column - 3 tag values 'a', 'b', 'c' with ro

Create a PersistedFiles instance populated with the specified number of files. # Parameters - `file_count`: Number of ParquetFile entries to create

Returns a [`PhysicalExpr`] from the logical [`Expr`] and Arrow [`SchemaRef`]

Returns a [`PruningPredicate`] from the logical [`Expr`] and Arrow [`SchemaRef`]

Create a set of queriers to perform queries in parallel

Generate a set of queries off of a query spec This produces a Vec so that certain [`QuerySpec`]s can result in multiple queries per interval.

Convert a series of record batches into a table NB: COPIED FROM ARROW

Helper function to create a test ParquetFile

Helper to create a PersistedSnapshot with multiple databases and tables

Helper to create a table index snapshot

Helper function to create a test table index

Helper to create a TableIndexSnapshot

Create a token with permissions using a pre-computed hash

Read access to the created_at time. This should be set by the catalog.

Create an expression to represent the `CUMULATIVE_SUM` function.

Node id of the running process, falling back to the catalog id when no current node is configured (e.g. single-process core).

Returns a reference to this column's data

Inputs for [`DataSourceExec`]. See [`DataSourceExecInput`] for more information. [`DataSourceExec`]: datafusion::datasource::memory::DataSourceExec

Returns the deletion status of a database by its ID. If the database exists as is not marked for deletion, `None` is returned.

Classify DataFusion errors into HTTP status codes. Keep this as the single mapping point so new DataFusion variants can be added in one place.

Return the UDF for the date_bin function wrapped by this virtual function, if this is a GapFill function.

Map the InfluxQL scalar function call to a DataFusion scalar function expression.

Names of databases that have not been soft-deleted.

Decodes headers in the B3 format

Decodes headers in the Jaeger format