Extends the provided batch with random content, returning a summary of what was written

Extends this [`PackedStringArray`] by `range` elements from `other`

Extend this [`MutableBatch`] with `range` rows from `other`

Parse the `ON` clause of the `SHOW MEASUREMENTS` statement.

Traverse expressions of all `fields` and expand wildcard or regular expressions either at the top-level or as the first argument of function calls, su

Create a file scan config with a given file [`SchemaRef`], ordering, and [`ColumnStatistics`] for multiple columns.

Returns a filtered version of `self` based on the provided `ranges`

Filters this sort key to contain only the columns present in the primary key, in the order that the columns appear in this sort key. # Panics Panics

Find distinct occurrences of `Expr::VarRef` expressions for the `select`.

Translate [`FlightError`] to [tonic code](tonic::Status). This is done by traversing the error chain, similar to [`datafusion_error_to_tonic_code`].

Flush the buffer by grouping writes by database and sending them

Converts the wal_buffer into contents and resets it. Returns the channels waiting for responses. If a snapshot should occur with this flush, a semapho

Generate realistic column names similar to what would be seen in InfluxDB

The generation of this entry

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

Get the list of files for a given database and table, using the provided filter to filter results. Always return in descending order of min_time

Gets the influx type for a field

Obtain a [`watch::Receiver`] that receives the latest [`Stats`] as they are published. Statistics are refreshed every [`REFRESH_INTERVAL`]. Callers

Check if request has IOx debug header set.

Plan an InfluxQL query and return a DataFusion physical plan

Read access to the inner proto

Return a mutable reference to the inner stream

Parse an InfluxQL integer. InfluxQL defines an integer as follows ```text INTEGER ::= [0-9]+ ```

Intern schema.

Creates a consuming iterator visiting all parameter values. Currently this will iterate in an arbitrary order, but specific ordering is subject to cha

Remove a specific entry from the cache

inverts casts on a time column expression and applies them to a time range bound expression the `time_col_expr` is a reference to the gapfill time co

Returns if this sort key is empty

Check if database has default user, org, bucket

Returns `true` if the specified name is a tag field or a projection of a tag field if the `DataSource` is a subquery.

Returns true if the given `expr` is a reference to the `time_col`, optionally wrapped by any number of `Alias` or timestamp `Cast` expressions

Returns true if the conditional expression is a single node that refers to the `time` column. In a conditional expression, this comparison is case-in

IsZero returns true if this is a zero duration. Original: <https://github.com/influxdata/flux/blob/1e9bfd49f21c0e679b42acf6fc515ce05c6dec2b/values/ti

Build a schema for testing iterators

Load the log file at `sequence_number`, or `Ok(None)` if absent.

Performs a lookup of `value`

Returns the str in self.dictionary that corresponds to `id`

create a new span connected to the collector

Set optional InfluxDB data model measurement name

Merge partition stats across plan inputs. Apply fetch variables (fetch/skip) to modify the [`Statistics::num_rows`]. This does not perform any schema

Merge a collection of [`Statistics`] into a single stat. This takes statistics references, which may or may not be arc'ed.

Panic message.

Returns mutable access to the inner [`Span`] metadata.

Returns the observation set for a given metric name if any

Return a new session config, suitable for executing a new query or system task. Note that this context (and all its clones) will be shut down once `E

Get object-store path.

Returns the observation for a given set of attributes if any

Returns an iterator over the strings in a [`PackedStrings`] # Panic If the offsets array is not an increasing sequence of numbers less than the leng

Try to parse a JSON error response body with `error_code` and `message` fields. Returns `(message, error_code)`. If JSON parsing fails, treats the bod

Create a collection of [`PartitionWrite`] indexed by partition key from a [`MutableBatch`] and [`TablePartitionTemplateOverride`]