Returns true if any of the neighboring [`Self::value_ranges`], when ordered by [`Self::indices`], have the same sort key.

Search `cond` for expressions involving the `time` column.

Returns true if the "WITH" clause is present.

The unique hash derived from the table ID and partition key

hash repartition into the specified number of partitions

return the number of pending holders

Returns the hour number from 0 to 23.

This applies murmur3 32 bit hashing to the tag value string, as Iceberg would. <https://iceberg.apache.org/spec/#appendix-b-32-bit-hash-requirements>

Check if a resource exists in the repository by `id` and `name` # Panics This panics if the `id` is in the id-to-name map, but not in the actual rep

Check if a resource exists in the repository by `id` and `name` # Panics This panics if the `id` is in the id-to-name map, but not in the actual rep

Check if a resource exists in the repository by `id` # Panics This panics if the `id` is in the name map but not in the repository (or vice-versa),

Check if a resource exists in the repository by `id` # Panics This panics if the `id` is in the id-to-name map, but not in the actual repository map

Check if a resource exists in the repository by `id` # Panics This panics if the `id` is in the id-to-name map, but not in the actual repository map

Increment the local value for this CumulativeRecorder

Helps the compiler to infer certain [`Future`] types, esp. when the future only contains a single panic statement.

infer_precision returns a precision for the given timestamp, inferring if Auto is the initial precision; this method never returns the Precision::Auto

Logically plan an InfluxQL query against the data in `database`, and return a DataFusion logical plan.

Physically plan an InfluxQL query against the data in `database`, and return a DataFusion physical execution plan.

Start building the one-per-process venv on a background thread so it overlaps with the rest of startup. Call [`PendingVenv::ready`] to wait for it.

This method is intended to run at startup to make sure that `TableIndex`s exist for each table and that each one is update to date with the latest `Pe

Initialize an admin token from a JSON file. The token file must be in this format: `{"token": "apiv3_...", "name": "custom_name", "expiry_millis": 12

Get the wrapped UDF.

Input

Insert a [`TableDefinition`] to the `tables` map and also update the `table_map` and increment the database next id. # Implementation Note This meth

Insert a [`TableDefinition`] to the `tables` map and also update the `table_map` and increment the database next id. # Implementation Note This meth

Return a reference to the global iox & datafusion function registry

Return a reference to the global iox function registry

Create an expression to represent the `INTEGRAL` function. INTEGRAL is represented as a SUM wrapping an internal integral window function.

Return the intersection of `self` and `other`.

Update the receiver so it is the intersection with `other`.

A private variant of [`Self::build_from_key`] that consumes the builder. This is used by the public [`TablePartitionTemplateOverride::column_values`]

Convert into a HashMap of (name, value) pairs

Return the raw partition key, consuming this struct.

Converts a result from the business logic into the appropriate tonic (gRPC) status message to send back to users

Use mostly default file formats, but apply iox-specific [`TableParquetOptions`].

Returns `true` if `name` is an aggregate or aggregate function supported by InfluxQL.

Return `true` if all bits in the [`BitSet`] are currently set.

Return `true` if all bits in the [`BitSet`] are currently unset.

Allowlist of chars for a [`NamespaceName`] name. '/' | '_' | '-' are utilized by the platforms.

Allowlist of chars for a [`DatabaseName`].

returns the column name for an expression like `IS NULL(col)`

Return `true` if there are no [`SequenceNumber`] in this set.

Determines if an HTTP request is a gRPC request based on version and content-type

Returns true if the partition key generated by `self` for `idx` will be identical to the last generated key.

port of fun isLeapYear(year int) bool { Original: <https://github.com/influxdata/flux/blob/1e9bfd49f21c0e679b42acf6fc515ce05c6dec2b/values/time.go#L50

True when `err` is a `ModuleNotFoundError` for `module_name` itself, so no plugin code has run and re-importing is side-effect free.

Returns `true` if the specified name is a tag from the perspective of an outer query consuming the results of this subquery or table. If a subquery ha

Returns true if `self` and `other` are of the same data type.