Parse a SHOW statement.

Parse a single-quoted literal string.

Resort order of our columns lexicographically by name

Splits up the namespace name into org_id and bucket_id

Serialize a value as JSON (pretty).

Record that this query completed successfully

Returns true if `self == TaskResult::Success`

The uninitialized part of the buffer. This can be used as a target for I/O operations. After writing data in, call [`bump`](Self::bump) to specify th

Helper to create a test catalog.

Build a [`SortKey`] from [`SortKeyIds`]; looking up column names in the provided [`ColumnsByName`] map by converting it to a `HashMap<ColumnId, &str>.

Get the total request count accross READ-style requests for a specific `Path` in the inner object store.

Convert all the data in this `MutableBatch` into a `RecordBatch`, consuming self. Note this panics if the `projection` contains a column that does no

Create a memory pool that has no limit

Perform (not assert): upload based upon [`UploadType`]

Return the InfluxQL type of the value.

Perform a depth-first traversal of the arithmetic expression tree.

Configure a predicate that determines which operations are eligible for failure injection

Provide settings for parallelized writes. Settings determine the amount of parallelization per row group and per column. # Panics This will panic if

Enable the admin token recovery endpoint

Validate that a key does not contain spaces, commas, or equals signs.

Accept that we will have a [`Slice`] available at some point. After calling this function, the sender MUST provide a slice at some point. Dropping th

Add a new chunk to this provider

Parse an arithmetic expression used by conditional expressions.

Get the arrow [`SchemaRef`] for this cache

Borrow a string slice of the name.

Assert that `put_adaptive_impl` routes `payload` through `expected` AND round-trips the bytes intact. Wraps `InMemory` in a `TestObjectStore` that fa

Check that a given object implements [`Sync`].

Capture a stable backup view: the live snapshot (checkpoint) plus the log files that follow it up to the current live sequence. The upper bound is ca

Build client.

Helper method that iterates over each series that ends with offsets in `series_ends` and produces the appropriate output values.

Test call expressions using `ConditionalExpression`

Validate that `expr` is either a [`Expr::VarRef`] or a [`Expr::Wildcard`] or [`Literal::Regex`] under specific conditions.

Return the InfluxDB type of the column.

Get the names of the columns in this SeriesChunk.

Create a test snapshot with minimal data

Resolve the current node's [`NodeDefinition`] from the registry. Errors if no current node is configured or if the configured id is not registered.

Decode series keys from a base64 string with length-prefixed format. This is the inverse of [`encode_series_key_v2`]. # Errors Returns an error if:

Removes the [`CacheValue`] for the given `key` if any

Wait for the barrier and then return `result`

Perform (not assert): download

When a `next_id` in the v2 snapshot exceeds the derived `next_id` from the migration, emit a `SetNextId` record into the catalog to fill the gap. Such

Record an error on this `Span` setting the status if it isn't already set

Executes the physical plan and produces a `SendableRecordBatchStream` to stream over the result that iterates over the results. The creation of the st

Extend this [`MutableBatch`] with the contents of `other`

Parse the request: trace context, auth token, and body params/format. Splitting this out from execution lets callers inspect the resolved `database`

Map the fields to DataFusion [`Expr::Column`] expressions, excluding those columns that are [`DataType::Null`]'s.

Find the index of the column with the given name, if any.

Parse an unsigned InfluxQL floating point number. InfluxQL defines a floating point number as follows ```text float ::= INTEGER "." INTEGER INTEGE

Flush content.

Free `size` bytes