Ensure that there is a delay between steam responses.

Create [`Fields`] for the output struct.

Map the fields to DataFusion [`Expr::Sort`] expressions, excluding those columns that are [`DataType::Null`]'s, as sorting these column types is not s

Mark that a checkpoint was just created.

Returns the maximum sequence number contained by the set, if any.

Return the max value at the specified index as a list of single row arrays Used for debugging

Spawn a background checkpoint task if both the concurrency slot is available and a threshold (log count or wall-clock time) has been crossed since the

Reduce the precision of the timestamp iff using the default "%Y-%m-%d" formatter string, returning a value rounded to the nearest whole day. If the f

Merge another checkpoint into this one. The `other` checkpoint should be chronologically later than `self`. This method: 1. Adds all files from `othe

Merge partition stats across plan inputs. This does not perform any schema projection.

Two independent runs against equivalent v2 inputs must produce byte-identical v3 snapshots — the synthesis is map-iteration- deterministic, and apply

Return the min value at the specified index as a list of single row arrays Used for debugging

Logic for rewriting expressions from influxrpc that reference non existent columns, or columns that are not tags, to NULL.

Mul will multiply the Duration by a scalar. This multiplies each component of the vector. Original: <https://github.com/influxdata/flux/blob/1e9bfd49

multiplier returns the value needed to scale a timestamp with precision units to nanoseconds. The returned value is also suitable to use for truncatin

Number of tombstones.

Name.

Create new statistics with no values

Returns whether this expression is nullable when evaluated against the given schema. The result is nullable if either the expression or the default v

Returns a list of `ObservationSet` for each reported metric

Calculate the offset in nanoseconds that needs to be added to a local timestamp to get a UTC timestamp in a timezone. If the time represented by `loc

Physical planning completed (the underlying `QueryLogEntry` reached the `PhysicallyPlanned` state). Will not fire on queries that fail during logical

Returns a set of batches like this: tag1, field1, field2

Return the legacy column ID, when one is assigned. Columns added to a PachaTree-mode table after `u16::MAX` ids have been assigned will return `None`

Return a reference the column ordinal ID when one is assigned.

Return a reference to the column ordinal ID.

Iterator over the in lexical ranges in order

Sort key that was passed to [`chunks_to_physical_nodes`]. This is NOT used to set the output ordering. It is only here to recover this information la

Return true if at least 2 min_max ranges in the given array overlap

Helper to contruct [`TableParquetOptions`] for parallelized writes. The configuration used here should be the same as in [`writer_props`].

Return the parameter schema for the specified map of parameters. Map can be produced from [LogicalPlan::get_parameter_types]

This is a copied version of nom's `separated_list` that allows parameterizing the created collection via closures.

An error that was the result of invalid InfluxQL bind parameters.

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

return row group metadata

Decodes and parses a given header from the provided HeaderMap - Returns Ok(None) if the header doesn't exist - Returns Err if the header fails to dec

Check if an entry in the cache is in process of being fetched or if it was already fetched successfully This does not update the hit time of the entr

Calculate the location in an ordered list of len items where the location of the item at the given percentile would be found. Note that row numbers a

Persist an `OrderedCatalogBatch` to the object store catalog. This handles broadcast of catalog updates for any unseen catalog files that need to be f

Writes a [`SendableRecordBatchStream`] to the Parquet format and persists it to Object Store at the given path. Returns the number of bytes written an

Persist an `UpgradedLog` marker as the v2 log file at `sequence_number`, terminating any further v2 mutations. # Note This is a "v2" method but is o

Convert a multi-column ScalarValue row to columns

Create a plan that sorts the input plan. The ordering of the results is as follows: iox::measurement, [group by tag 0, .., group by tag n], time, [p

Trigger a jemalloc heap profile dump and build a streaming Response containing the resulting `heap_v2` bytes. Profiling must be enabled at process st

Pre-load any `RestoreCatalog` record's backup state from object store. Async; runs outside the catalog's write lock. The returned [`RestorePreload`]

Prepare an arrow Schema for transport over the Arrow Flight protocol Converts dictionary types to underlying types due to <https://github.com/apache/

Given the output ordering and a projected schema, returns the largest prefix of the ordering that is in the projection For example, ```text output_o