Execute a previously parsed V1 request.

Recursively expand the `from` clause of `stmt` and any subqueries.

Rewrite the projection list and GROUP BY of the specified `SELECT` statement. The following transformations are performed: Wildcards and regular exp

Produce the gzip encoding the client is expected to put on the wire for the given input. Stays in sync with `WriteRequestBuilder::send` (default compr

Get the [`InfluxColumnType`] representing the type of value that we can push to this builder.

Check in an expression is marked as being filled.

Returns the index of the given expression in the schema, assuming that it is a column. # Panic Panics if the expression is not a column.

Extends the record batch, if needed, so that it matches the schema

Extends this [`PackedStringArray`] by the contents of `other`

Extends this [`BitSet`] by `range` elements in `other`

Add any additional features to the session state that are provided by this extension. The default implementation returns the provided `state` unchang

Parse the core config file and extract all documented option names. Options are in the format: #option-name="value" or #option-name=value

Extract IOx statistics from parquet statistics. Note could use [`StatisticsConverter`] to convert parquet statistics to arrow statistics or [`statist

Extract all public (non-hidden) argument long names from a Command recursively. Returns a HashSet of option names (without the leading "--").

Attempt to extract LexicalRanges for the given sort keys and partitioned file groups. Since the goal is to have as many non-overlapping ranges as pos

Returns the underlying string for a tag column, if any, for the ScalarValue `Some(Some(str))` for non null string literals `Some(None)` for null stri

Extract user-provided parameters from ArgMatches using clap's ids() Returns a simple map of CLI argument name -> string value for all user-provided ar

Extract the authentication token for v1 API requests, which may use the `p` query parameter to pass the authentication token.

Combine two decisions but favor [eviction](Self::Evict).

Determine the lowest common denominator of feature level for both Core and Enterprise across all _running_ nodes in the cluster.

Returns the expression that matches the field name. If the name matches one of the arguments to "top" or "bottom", the variable reference inside of t

Ensures the `time` column is presented consistently across all `SELECT` queries. The following transformations may occur Ensure the `time` field is

Returns the name of the field. Prefers the alias if set, otherwise derives the name from [Expr::VarRef] or [Expr::Call]. Finally, if neither are avai

Map an InfluxQL [`Field`] to a DataFusion [`Expr`]. A [`Field`] is analogous to a column in a SQL `SELECT` projection.

Return a random field value

Returns the value of the passed-in field, if present.

Resolve the projection list column names and data types. Column names are resolved in accordance with the [original implementation]. [original implem

Size of the parquet file in object store

Produces the arrays for the aggregate columns in the input. The first item in the 2-tuple is the arrays offset in the schema.

Apply a time range filter to the `plan` based on the original specified time filters (expanded to account for grouping). This will remove any rows fro

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. Does not verify

Collect all deeply nested `Expr::AggregateFunction`. They are returned in order of occurrence (depth first), with duplicates omitted. along with a cou

Scan forward to find the endpoint for a segment that starts at `start_offset`. Skip over any null values. We are guaranteed to have buffered enough i

Search an `Expr`, and all of its nested `Expr`'s, for any that pass the provided test. The returned `Expr`'s are deduplicated and returned in order of

Return the index of the given column and its sort option. Return None otherwise.

Return the interval value of the `GROUP BY` clause if it specifies a `TIME`.

Retrieve a label by ID

Use a binary heap to find the time before which all nodes should be removed

Return the `(batch_idx, row_idx)` of the `nth` row.

Used in queries to the system.{table_name} table # Example ```sql SELECT * FROM system.parquet_files WHERE table_name = 'foo' ```

Find all [`ScalarUDF`] expressions that match one of the supported window UDF functions.

Produce the final value which will then be stored in a [`TableBatch`]. This will return [`None`] if there were no nonnull values pushed to this column

Get the flags for this record.

Creates a plan for a `DoAction` FlightSQL message, as described on [`FlightSQLPlanner::do_action`], on a separate threadpool

Creates a logical plan for a `DoGet` FlightSQL message, as described on [`FlightSQLPlanner::do_get_logical_plan`], on a separate threadpool

Creates a physical plan for a `DoGet` FlightSQL message, as described on [`FlightSQLPlanner::do_get_physical_plan`], on a separate threadpool

Creates a plan for a `DoPut` FlightSQL message, as described on [`FlightSQLPlanner::do_put`], on a separate threadpool

Returns the [`SchemaRef`] to be included in the response to a `GetFlightInfo` FlightSQL message as described on [`FlightSQLPlanner::get_schema`], on a

Renders this template to `out` for the row `idx`.

Forget generation.

Recursively drop any measurements of the `from` clause of `stmt` that do not project any fields.

Determine the merged fields and tags of the `FROM` clause.

Produce a record batch listing parquet file information based on the given `schema` and `parquet_files`, a list of table name and parquet file pairs.

Determine the combined tag set for the specified `from`.

calculates the size as accurate as possible, call to this method is expensive

Fuse neighboring groups if they don't require de-duplication.