Push the metrics stored in the internal [`Registry`] to the configured server.

Push a null value. If this builder is building a time column, this function will return an error since time columns must have no null values.

Ensures that the total length of this column is `len` rows, padding it with trailing NULLs if necessary

Append a new value by hash, returning the bucket index

Get the full path used for the Prometheus PushGateway, containing the interpolated server address and the job name.

Python component. Note that the returned [`WasmComponentPrecompiled`] is stateless and hence can (and should) be reused. State only exists once it is

NOTE: this method is separated out as it is called from a separate query executor implementation in Enterprise

Inner function for performing InfluxQL queries via the `/api/v3/query_influxql` endpoint. The `/api/v1/query` endpoint goes through `iox_v1_query_api:

Make random 16 digit string

Returns random non-overlapping ranges in increasing order with a max of len

A random unicode string of up to 20 codepoints

Read IOx statistics from parquet row group metadata.

Read parquet file into [`RecordBatch`]es. This should only be used for testing purposes.

Get the readiness of an instance at startup

Future is [ready](Poll::Ready).

Block until the background venv build finishes. The returned [`ReadyVenv`] is the only handle to the built venv and the entry point for operating on

Rebuilds an `Expr` as a projection on top of a collection of `Expr`'s. For example, the expression `a + b < 1` would require, as input, the 2 individ

Reduce `integer OP expr`. ```text integer = integer ( ADD | SUB | MUL | DIV | MOD | BitwiseAND | BitwiseOR | BitwiseXOR ) integer float = integ

Reduce `string OP expr`. If `expr` is a string, concatenates the two values and returns a new string. If `expr` is a duration, integer or timestamp,

This method picks the memory and cpu usage for this process using the pid.

Weak pointer that can be used for ref-counting this execution plan and its streams. Use [`Weak::strong_count`] to determine if the plan itself and it

Register IOx-specific [`AnalyzerRule`]s with the SessionContext [`AnalyzerRule`]: datafusion::optimizer::AnalyzerRule

Register IOx-specific logical [`OptimizerRule`]s with the SessionContext [`OptimizerRule`]: datafusion::optimizer::OptimizerRule

Register IOx-specific [`PhysicalOptimizerRule`]s with the SessionContext

registers iox scalar functions into the [`SessionContext`] so they can be invoked via SQL

registers iox window functions into the [`SessionContext`] so they can be invoked via SQL

Register a cache MISS for the given object store path and object size (in bytes).

registers selector functions so they can be invoked via SQL

Remove expired values from the internal cache state

Remove a file from the checkpoint and adjust metrics. Returns true if the file was found and removed.

Remove multiple keys from the cache, in a blocking manner. This method directly removes entries from the cache without going through the normal evict

Remove the `n_to_remove` oldest entries from the cache

This removes the user from the oauth_lookup map without clearing out the oauth field on the user record. That's so we can restore later to this

Remove all the [`SequenceNumber`] in `other` from `self`.

Remove the user from the username_lookup map without clearing the username/password identity on the user record. This allows the username to be reused

Count `(databases, tables, files)` in the `removed_files` collection.

Transforms an InfluxQL [Statement] by replacing [Expr::BindParameter]s that match the given [StatementParam]s Will error if a parameter is not found

Iterate over the group expression list. If it finds no occurrences of date_bin_gapfill, it will return None. If it finds more than one occurrence it w

Find the expression that matches `e` and replace its fill strategy. If such an expression is found, return the old strategy, and `None` otherwise.

The database name as supplied by the request — URL query string, `application/x-www-form-urlencoded` body, or multipart `db` field. Empty strings coll