Decodes [`proto::Predicate`] from base64 string.

Decode [`ListEntry`] from a v2 list response

Decode [`Schema`] from response data stream.

Decrement the local value for this CumulativeRecorder

Check if a [ColumnDefinition] exists in the repository by `id`, `name`, and (when present) `ord_id`. # Panics This panics if the `id` is in the name

Check if a [ColumnDefinition] exists in the repository by `id`, `column_id` and `name` # Panics This panics if the `id` is in the id-to-name map, bu

Delete an object on object store, but also remove it from the cache.

Helper to delete all snapshot files from object store. Used to prove that checkpoint loading works independently of snapshots.

Delete a cache from the provider This also cleans up the provider hierarchy, so if the delete leaves a branch for a given table or its parent databas

Delete a cache from the provider This will also clean up empty levels in the provider hierarchy, so if there are no more caches for a given table, th

Delete all caches for a given database

Delete all caches for database from the provider

Delete all caches for a given database and table

Delete all caches for table from the provider

Delete a Label

Delete the username/password login identity for a user

Create an expression to represent the `DERIVATIVE` function.

Derive min/max time from column statistics. # Panics This method panics if the [`IoxParquetMetaData`] structure does not contain valid metadata byte

Add flag to group to detect if they need de-duplication.

Determines the field family mode by analyzing the field columns in the table definition. # NOTE A table is expected to be [FieldFamilyMode::Aware].

Probe pip *inside* the built venv and pick the matching manager: `PipManager` if `python -m pip` works there, otherwise `DisabledManager`. pip lives

Create an expression to represent the `DIFFERENCE` function.

used with both `Expr` and `PhysicalExpr`, normally to display this within `explain` queries

Takes batches of data and the columns that make up the primary key. Computes the number of distinct values for each primary key column across all batc

Distribute items from the given iterator into `n` containers. This will produce less than `n` containers if the input has less than `n` elements. #

Handles the action specified in `msg` and returns bytes for the [`arrow_flight::Result`] (not the same as a rust [`Result`]!)

Calls `DoGet` with the provded FlightInfo, which is normally retrieved by calling [`Self::get_flight_info_for_command`]. This method allows one to pro

Handles receiving the given `data` from the client based on the action specified by `cmd` and returns bytes for the [`arrow_flight::Result`] (not the

Implements the DoPut method for sending a stream of FlightData to the server:

Download file to path.

Get download location.

Drop the last buffer entry. This may cause spurious cache misses due to the short-circuiting search observing an empty element, potentially before no

Remove the last wrote value. # Reference Leak This call removes the encoded value from the buffer. If this call removes the sole reference to a val

dry_run_wal_plugin doesn't write data to the DB but it does perform real queries. If the plugin under test does other actions with side effects those

Convert [`DynError`] to [`object_store::Error`].

Extract the early access data if present. Returns None for WasCached states or when no early access data was provided. Returns Some(data) for Already

Create an expression to represent the `ELAPSED` function.

Encodes the Arrow schema into the IPC format, and base64 encodes it. This method is copied from a private method in the arrow-rs upstream code. (Refe

Encodes [`proto::Predicate`] as base64.

Enforce retention for a specific table.

Ensure that this semaphore has at least this amount of permits in total. If the semaphore size was changed the delta will be returned.

Returns true if the [`PartitionedFile`]s are equal, excluding consideration of ranges.

Returns true if the output of rendering `timestamp` will match the last rendered timestamp, after optionally applying the precision reduction optimisa

Evaluate the datatype of the function identified by `name`. Derived from [Go implementation](https://github.com/influxdata/influxql/blob/1ba470371ec0

Evaluate the data type of a scalar function See: <https://github.com/influxdata/influxdb/blob/343ce4223810ecdbc7f4de68f2509a51b28f2c56/query/math.go#

Evaluate [`WithKeyClause`] on the given list of keys. This may fail if the clause contains an invalid regex.

Evaluate a predicate against a [`Node`], producing a list of [`Value`]s and, if this is a branch node in the cache tree, a reference to the next [`Nod

Evaluate the provided [`Predicate`] by using its value to lookup in this [`LastCacheKey`]'s value map.

Evaluate the set of provided predicates against this node, adding values to the provided [`StringViewBuilder`]s. Predicates and builders are provided

Run eviction across all caches in the provider.

Recurse down the cache structure to evict expired cache entries, based on their respective time-to-live (TTL).

Evict at most one entry from the "main" queue. This scans through the "main" queue and for every entry it either: - **move to to back:** If the entr

Evict at most one entry from the "small" queue. This scans through the "small" queue and for every entry it either: - **move to "main" queue:** If t

Stream split has multiple partitions from 0 to n Each partition i includes rows for which `split_exprs[i]` evaluate to true # Deadlock This will dea