Creates a new client with the provided connection

Creates a new FlightSql client that connects to a server over an arbitrary tonic `Channel`

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new client with the provided connection

Creates a new batched write client with the given configuration.

Creates a new client with the provided [`Connection`]. Panics if the metadata in connection is invalid for the underlying tonic library.

internal constructor. use [`super::Client::query`] as the public constructor

Create a new QueryLog that can hold at most `size` items. When the `size+1` item is added, item `0` is evicted.

Creates new aggregator the given schema. This will start with: - 0 rows - 0 bytes - for each column: - 0 null values - unknown min value - unknown m

Create new factory based on the given object store.

Creates a new `TestCaseBuilder` instance with default values.

Create new optimizer rule.

Create a new VirtualFunctionFinder that will populate the `functions` vector.

Create new optimizer rule.

Create a new `StreamSplitNode` using `split_exprs` to divide the rows. All `split_exprs` must evaluate to a boolean otherwise a runtime error will occ

Return a stream that records DataFusion `MetricSets` from `physical_plan` into `span` when dropped.

Register new pool.

Create a new PhysicalLimitExpr.

Initialize a [GapFiller] at the beginning of an input record batch.

Create a new progressive execution plan

Create a new chunk list with the specified chunk and overall sort order. If the desired output sort key is specified (e.g. the partition sort key) als

Create a new reorder partitions execution plan

Create a new [`PartitionWrite`] with the entire range of the provided batch # Panic Panics if the batch has no rows

Initialise a new [`StrftimeFormatter`] with the given stftime-like format string. The exact formatter specification is [documented here]. If the for

Create new observer.

Create new rate limiter using the given config.

Create a new static tag for all jaeger spans.

Creates a new `AsyncExporter`

Record permissions-check duration metrics, broken down by result.

Create a new Authorization object

Construct new extension wrapper for a possible header value

Create new keep-alive wrapper from the underlying stream and the given interval. The interval is measured from the last message -- which can either b

Create a new request to run the specified query

Create a new planner that will plan queries using the provided context

Create a new builder to contain values of the same variant as `value`, with `preceding_null_values` coming before `value` as the initial value

Create a new [`SystemTableProvider`]

Create a new disk space snapshot.

Create new metrics that are linked to the given registry and carry the given attributes.

Creates a new task tracker from the provided registration

Wrap an error in DisplaySourceChain

Create a new `DurationHistogramOptions` with a list of thresholds to delimit the buckets

Create a new `U64HistogramOptions` with a list of thresholds to delimit the buckets

Instrument `T`, pushing to `registry`.

Create a new [`ObjectStoreCacheMetrics`].

Construct a new [`Stats`]. Intentionally non-pub to enforce a singleton exposed via [`STATS`].

Create new stream. Must at least pass one record batch!

Create a new [`Backoff`] from the provided [`BackoffConfig`]. # Pancis Panics if [`BackoffConfig::base`] is not finite or < 1.0.