Apply the current transaction to the [super::InnerCatalog] and return the updated [DatabaseSchema]. # NOTE Used for testing purposes.

A test helper function for asserting floating point numbers are within the machine epsilon because strict comparison of floating point numbers is inco

Strategy for generating any ColumnarValue (scalar or array of given length)

Generate a [`FieldValue`] of arbitrary type.

Generate an arbitrary timestamp.

Return true if ranges are disjoint assuming the ranges are sorted by `ordered_by_min_partition_indices` This checks each pair of adjacent ranges in t

Map an InfluxQL arithmetic expression to a DataFusion [`Expr`].

Convert the value at `column[row]` to a String Special cases printing Timestamps in RFC3339 for IOx, otherwise falls back to Arrow's implementation

Recursively fold [`Array`]s.

Return the Arrow schema view for the data provided by this provider

Extract i64 type.

Clone is used by Conductor.

ColumnarValue doesn't have a PartialEq impl, so we need a custom assertion

Assert that given future is pending. This will try to poll the future a bit to ensure that it is not stuck in tokios task preemption.

todo: this is copied from DF. When we move ProgressiveEval to DF, this will be removed Asserts that given future is pending.

Assert: roundtrip for multi-threaded.

Assert: roundtrip for single-threaded.

todo: this is copied from DF. When we move ProgressiveEval to DF, this will be removed Asserts that the strong count of the given [`Weak`] pointer con

A background task for pruning un-needed entries in the cache

Handle [`CacheRequest`]s in a background task This waits on the given `Receiver` for new eventual cache requests to be registered (via oracle). If a

Background task that listens for catalog updates and maintains distinct caches. This should be started explicitly after creating the provider.

Persist the `CatalogSnapshot` as a checkpoint in the background but don't check that the operation succeeds.

Returns a batch with a different scheam

Iterate over the `CatalogBatch`s in the update

Map an InfluxQL binary conditional expression to a DataFusion [`Expr`].

Determine the data type of the binary expression using the left and right operands and the operator This logic is derived from [InfluxQL OG][og]. [o

Returns the name of a binary expression by concatenating the names of any [Expr::VarRef] and [Expr::Call] with underscores. Derived from [Go implemen

Turn any request into a boxed trait object request with boxed errors.

Called when the wal has persisted a new file. Buffer the contents in memory and update the last cache so the data is queryable.

Called when the wal has written a new file and is attempting to snapshot. Kicks off persistence of data that can be snapshot in the background after p

Produce a gap-filled array for the aggregate column in [`Self::aggr_col_states`]. # Panics Will panic if [Cursor::aggr_col_states] does not contain

Encode an empty [`RecordBatch`] as a message. This must only be sent AFTER a [`Schema`] was transmitted.

Hand-build an indexless flat snapshot file as written between #4026 and the compat-entry writer: header with `group_count: 0`, then the record bytes w

Returns a [`LogicalPlan`] that performs gap-filling for the `input` plan. # Arguments `input` - A plan which requires gap-filling, it is required th

Produces a gap-filled output [RecordBatch]. Input arrays are represented as pairs that include their offset in the schema at member `0`.

Hand-build a legacy multi-group snapshot file: header, then one 24-byte index entry per (group, records) pair — Global first — then the record bytes o