Push a new RecordBatch into the indexer. Returns a deduplicated RecordBatch and remembers any currently opened groups

Push a new value into the ring buffer If a value with the given key already exists, it will replace the value Otherwise it will add the key and value

Removes a parameter from the map by name, returning the parameter value if the name was previously in the map.

Create a sort_preserving_merge with the specified sort order

Get current state.

Store that contains this file.

Add the InfluxDB data model timestamp column

Set the auth (setting this will auto generate admin token)

Stops all subsequent task executions, and waits for the worker thread to complete. Note this will shutdown all created contexts. Only the first all t

Logged lines.

Remove the last [`Value`] from this bitmap. This operation is `O(1)` unless the resulting bitmap contains trailing 0 bytes, where it is `O(bytes)`.

Set the sort key for this chunk

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

Fetches the value of this U64Gauge

Insert a new resource to the repository

Create a SpanContext for the trace described in the request's headers, if any Currently support the following formats: <https://github.com/openzipkin

Gets the `MetricsRecorder` for a given http request

Return the raw packed bytes used by this bitset

Empty response body when there's no content to return.

Get a [`FlightSqlClient`] for making requests to the running service over gRPC

Return the identifier of the column.

Returns all levels

TODO(trevor): remove thid API in favour of the Repository APIs

Commits the writes performed on this [`Writer`]. This will pad any unwritten columns with nulls

Consume the indexer, returning any remaining record batches for output

Get the number of values in the cache that have not expired past the TTL.

Push a [`Row`] from the write buffer into the cache If a key column is not present in the row, the row will be ignored. # Panics This will panic if

Returns the schema for a given projection If [`Projection::All`] the returned columns are sorted by name

Set the auth token for this [`TestServer`]

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

Build a [`HashMap`] to be used as the DataFusion config for the query executor This takes the provided `--datafusion-config` and extends it with opti

Empty request body, properly typed. Mostly useful when constructing test requests.

Consume this [`LinesConverter`] returning the [`MutableBatch`] and the [`PayloadStatistics`] for the written data

Return `self >= other`

Current sequence number.

updates the statistics keeping the min, max and incrementing count. The type plumbing exists to allow calling with `&str` on a `StatValues<String>`.

Set the `may_contain_pk_duplicates` flag

Apply a slice of records to the catalog via the global registry. Each known record is decoded, applied, and its event collected. Unknown records with

Attempt to build [`self`], returning a [`MismatchedNumPartsError`] if validation fails. Validation fails only if the number of parts (which are delimi

Returns the duration since the provided time or None if it would be negative

Extends `self` with the writes from `other`

Check if a record ID is registered.

Given a `LogicalPlan` created from above, create an `ExecutionPlan` suitable for execution

Helper function to create a simple test input.

Check if the cache is empty

Appends the schema to the merged schema being built, validating that no columns are added.

Infallibly return the full schema (for all columns) for this chunk

Serialize the given `B` to json then send the request and return the resulting bytes.

Return a TableParquetOptions object configured for IOx This is a workaround until DataFusion supports retrieving these options from the DataSourceExec