Retrieve the given value from the remote cache, if present

Get string.

Returns if this bitset is empty

The key if it matches a known variant of [`CacheKey`] Returns `None` otherwise

Returns the kind of cache state for use in attributes and metrics.

Return last_batch if it does not overlap with the given batch Note that since last_batch, if exists, will include at least one row and all of its rows

Lists checkpoint paths and returns the latest path for each month. This is a lightweight operation that only lists paths without loading content. Ret

Loads all catalog files from object store to build the catalog

Returns `n` as a scalar value of the specified `data_type`.

Parses an InfluxQL [BindParameter].

Returns an iterator identifying consecutive ranges for a given partition key

Produce a partitioned set of record batches along with their min/max timestamp The partitions are stored and returned in a `HashMap`, keyed on the ge

Persist the `CatalogSnapshot` as a checkpoint and ensure that the operation succeeds unless the file already exists. Object Storage should handle the

Pre-load any restore state for a parsed [`CatalogFile`]. Convenience wrapper over [`preload_restore_for_records`] that handles both log and snapshot f

If an instrument already exists with the provided `name`, returns it Otherwise, invokes `create` to create a new `Instrument`, stores it in this `Reg

Remove element from the middle of the set. The relative order of the elements is preserved. Returns `true` if the entry was part of the set. # Runt

Transform a `SelectStatement` to a `Select`, which is an intermediate representation used by the InfluxQL planner. Transformations include expanding w

Perform a series of passes to rewrite `expr` in compliance with InfluxQL behavior in an effort to ensure the query executes without error.

Get the values at the given row.

Return the number of rows in this chunk

Start the [`DiskSpaceMetrics`] evaluation loop, blocking forever.

Schema with all available columns across all chunks

Serialize a snapshot file: header (SNAPSHOT flag set), one backward-compatibility group-index entry, then all records concatenated in slice (applicati

Sets the local value for this CumulativeRecorder

Set every generation duration in a single atomic batch. `durations[i]` configures level `i + 1`. Re-issuing identical durations is a no-op; mismatched

Triggers and waits for graceful shutdown

Return a schema with a single column `a` of type int64.

Get the size of the cache value's memory footprint in bytes

Split this [`PackedStringArray`] at `n`, such that `self`` contains the elements `[0, n)` and the returned [`PackedStringArray`] contains elements `[n

Query the given database with the given SQL query, returning a struct that can stream Arrow [`RecordBatch`] results.

Helper to create a test catalog.

Execute the [ExecutionPlan] with a default [SessionContext] and collect the results in memory. # Panics If an an error occurs

Gather a record batch from a cache given the set of predicates This assumes the predicates are well behaved, and validated before being passed in. Fo

Encode the request as a protobuf Ticket

Update sequence numbers from a snapshot.

Parse a `WHERE` clause.

Sets the etag

Add a key range

OSS has no stored-credentials concept; this only applies an explicit token flag, matching the Enterprise signature so shared command source compiles a

Add a [`PartitionDuration`] to a [`chrono::DateTime`].

Add the given column name and schema to this set of columns. # Panics This method panics if a column of the same name already exists in `self`.

Internal helper method to add a column definition