Returns the deletion status of a table by its ID within a specific database. If the table exists and is not marked for deletion, `None` is returned.

Test if a table with the specified `name` exists.

Check if a table exists by its name in the current transaction or in the database schema.

Branch to table-list subcommand

Return the table name

Return the correct FlightSQL name for the DataFusion TableType

return a tag value with given null probability and number of distinct values

Returns the value of the passed-in tag, if present.

If any buffered input batches are present, concatenates it all together and returns an owned batch to the caller, leaving `self.buffered_input_batches

Helper to create a test catalog.

Helper to create a test catalog.

Helper to create a test catalog.

Fake DataFusion context for testing that contains this store

Endpoint for testing a plugin that will be trigger on WAL writes.

Return the values in the time column in this batch. Returns an error if the batch has no time column. # Panics If a time column exists but its data

Sets the timestamp, replacing any existing timestamp. The value is treated as the number of nanoseconds since the UNIX epoch.

Provide a timestamp. It returns a builder whose type allows only closing the line. The precision of the timestamp is by default nanoseconds (ns) but

Returns a summary of the write timestamps in this chunk if a time column exists

Returns the number of nanoseconds since the last second boundary

Convert to an arrow representation with the provided set of keys and an optional null bitmask

Convert to base64 encoded protobuf format

Converts the parameters stored in this handle into a map of DataFusion [[ScalarValue]]s

Returns an IntervalMonthDayNano array with the given nanosecond values

An IOx-specific, streaming [`RecordBatch`] to parquet file encoder. This encoder discovers the schema from the first item in `batches`, and encodes e

Create a corresponding iox catalog's ParquetFile

Performs a parallelized parquet encoding and upload to object_store. Current implementation uses the [`ParquetSink`] from DataFusion, and uploads on

Given a `PartitionWrite` that holds a `RecordBatch` and some ranges, return a new `RecordBatch` containing only the rows in the ranges.

Produce a set of [`RecordBatch`]es from this extended state This converts any additional columns to arrow arrays which will extend the [`RecordBatch`

Build a [`SortKey`] from [`SortKeyIds`]; looking up column names in the provided [`HashMap<ColumnId, &str>`] map. If you have a [`Partition`][super::

Get raw u16 value.

Totally available memory size in bytes.

return the total number of permits (available + already acquired).

Translate the field name from tracing into the logfmt style

truncate the time using the duration. Porting note: this implementation was moved into Duration so we could safely assume that only month or nsec was

Truncates this dictionary removing all keys larger than `id`

truncateByMonths will truncate the time to the given number of months. Original: <https://github.com/influxdata/flux/blob/1e9bfd49f21c0e679b42acf6fc5

truncateByNsecs will truncate the time to the given number of nanoseconds. Original: <https://github.com/influxdata/flux/blob/1e9bfd49f21c0e679b42acf

truncate_to_precision rounds the provided nanosecond value towards zero to a multiple of precision. If it's auto, nanos is returned unchanged.

Try to acquire a single permit, returning [`tokio::sync::TryAcquireError::NoPermits`] immediately if there are no permits left. See [`tokio::sync::Se

Attempts to acquire an exclusive lock without blocking.

Attempts to acquire a shared lock without blocking.

Try to resize the central memory reservation to the currently allocated amount. It does not matter whether a thread attempts to grow or shrink the al

Decodes the app_metadata stored in a [`PutResult`] as a [`DoPutPreparedStatementResult`] and then returns the inner prepared statement handle as [`Byt

Extract a histogram typed value. # Panics Panics if the value is not a histogram.

Update the cached checkpoint with a single snapshot. Creates a new checkpoint for the month if cache is empty or stale (month rollover). On month rol

Update the current [`PlanContext::data`] based upon the children.