Write the boolean typed column identified by `name` For each set bit in `valid_mask` an a value from `values` is inserted at the corresponding index

Compose a request to the `/api/v3/write_lp` API # Example ```no_run # use influxdb3_client::Client; # use influxdb3_client::Precision; # #[tokio::mai

Finish building the line protocol and return the inner buffer.

Creates an Arrow schema with embedded metadata. All schema validation happens at this time. ``` use schema::{builder::SchemaBuilder, InfluxColumnType,

Return a child span of the specified name, if this SpanRecorder has an active span, `None` otherwise.

Computes a compacted representation of a given bool array

Derive the local feature level from the compiled record registry. Walks every `RegisteredRecord` in `inventory` and tracks the maximum sequence for e

Record that this query got an execution semaphore permit.

Construct the output [`HashBuckets`]

Returns if the given index is set

Get the current default retry parameters

Get parquet file metrics, file count, row count and size in MB

Returns the data type of this expression when evaluated against the given schema. This method ensures that both the expression and default value have

Permanently delete a table from the catalog. This function performs a hard deletion of a table, which means the table will be completely removed from

Returns a tuple indicating whether the specifies `SELECT` statement has any wildcards or regular expressions in the projection list and `GROUP BY` cla

Returns the ID of the Tracker - these are unique per TrackerRegistry

Add a new field column with the specified InfluxDB data model type

Provide a reference to the underlying Arrow Schema object

Returns true if this column contains no rows

IDs of databases and tables marked for hard deletion. `(db_id, None)` flags the database itself; `(db_id, Some(table_id))` flags a single table withi

Load the snapshot file, or `Ok(None)` if absent. Returns the decoded [`CatalogFile`] alongside its on-disk byte size so callers (notably SLL emission

Return the next `T` to be used.

Pop the next item from the queue that is ready to be processed.

Wrapper around DataFusion's `project` that preserves InfluxQL fill information in the schema metadata.

Match a fully-qualified, 3-part measurement name. ```text qualified_measurement_name ::= measurement_name | ( policy_name "." measurement_name ) | (

Register the "IOx" object store provider for URLs of the form "iox://{id} Return the previous registered store, if any

Reserve `size` bytes, returning an error if this would exceed the limit

Parse a segmented identifier ```text segmented_identifier ::= identifier | ( identifier "." identifier ) | ( identifier "." identifier? "." identifie

Completes once every subscriber has either dropped its [`CatalogUpdateMessage`] (firing the ACK) or transitioned to stopped while the message was in f

Parse the input for a InfluxQL duration fragment and returns the value in nanoseconds.

Register a named subscriber for catalog-update event broadcasts.

Create a scalar timestamp value for the given UTC nanosecond offset in the timezone specified by [TIME_DATA_TIMEZONE].

Truncate the [`CacheColumn`]. This is useful for evicting expired entries.

Update the rolling stats [`Self::min`]/[`Self::max`]/[`Self::avg`] using reference to an higher precision stats that is passed in. This is usually a p

Enable capturing of stdout/stderr logs for this [`TestServer`]

Register a string field column with the test chunk

Assert: roundtrip for both single- and multi- threaded.

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

Create a logical plan that reads a single [`RecordBatch`]. Use `create_physical_plan` to actually execute the query.

Bump initialized part of the buffer by given amount of bytes (= delta). # Panic There must be enough space left in buffer. # Safety The caller must

Check and perform a catalog migration from v1 → v2. If a v2 catalog already exists or there is no v1 catalog to migrate from, this function does noth

Get-or-create a column on a named table. Errors if the column exists with a different type.

Create a table in `db_name` with the given tag and field columns, using default options. The database is auto-created if it does not exist.

Create a test checkpoint with minimal data

Returns true if there are no more output rows to produce given the number of rows of buffered input.

Get the list of files for a given database and table, always return in descending order of min_time

Get a table index from the cache or load it from object store

Groups query chunks into disjoint sets of overlapped time range. Does not preserve or guarantee any ordering.

Permanently delete a database from the catalog. This function performs a hard deletion of a database, which means the database will be completely rem

De-construct service into parts. The can be used to call [`new`](Self::new) again.

Determine if the limited column can be nullable in the output.