Returns a merged file, if the partitioned files are adjacent table scans. Returns None if the ranged scans cannot be considered as an adjacent, conti

Update [Cursor::aggr_col_states] with updated state for an aggregate column. `cursor` will have been created via `Cursor::clone_for_aggr_col`, so [Cur

This function inserts an SPM above SortExecs, in order to enable to parallelize the SPM loser trees, while leaving the final ProgressiveEvalExec which

Merge together two [`Statistics`].

Extract string message from [`PanicHookInfo`]

Return a reference to gRPC metadata included with each request This can be used, for example, to include authorization or other headers with each req

Return a reference to gRPC metadata included with each request This can be used, for example, to include authorization or other headers with each req

Returns the min and max value for the [`Statistics`], and handles null values based on [`SortOptions`]. Returns None if statistics are absent/unknown

Returns the minute number from 0 to 59.

Return the number of months in this duration

Create an expression to represent the `MOVING_AVERAGE` function.

An iterator visiting all parameter names. Currently this will iterate in an arbitrary order, but specific ordering is subject to change and shouldn't

Return the set of column names. Used in combination with a write operation's column names to determine whether a write would exceed the max allowed co

Retrieve the database specified name

Generate [`NamespaceSchema`] protobuf from a `NamespaceId` and a list of tables. Useful to filter the tables returned from an API request to a particu

Return the number of nanoseconds in this duration

Determine if we need more input before we start processing.

return true if the string value already starts/ends with quotes and is already properly escaped (all spaces escaped)

compute the boolean compliment of the columnar value (which must be boolean)

A funky little method to get a tokio Instant that we can call `tokio::time::sleep_until()` on.

Return a mutable reference to the next slot to be overwrote. This method initialises the slot if it has not been previously used. This is like an "in

Set next available stream to current_input_stream Also prefetch one more input stream if not all of them are prefetched yet

Create an expression to represent the `NON_NEGATIVE_DERIVATIVE` function.

Create an expression to represent the `NON_NEGATIVE_DIFFERENCE` function.

Normalize lines for easy comparison

s/location=\"logfmt/tests/logging.rs:128\"/location=NORMALIZED/g

s/span=1/span=SPAN1/g

Return a new `StringArray` where each element had a normalization function `norm` applied.

s/time=1612187170712947000/time=NORMALIZED/g

s/ts=2024-09-11T15:58:59.413080195Z/ts=NORMALIZED/g

Length of values in range.

The number of wal periods we need to see before we attempt a snapshot. This is to ensure that we don't snapshot before we've buffered up enough data t

Get underlying object store.

Get the Object Store URL

Return a `Display`able structure that produces a single line, for this node only (does not recurse to children)

Notifier for out-of-memory.

Notifier for out-of-memory.

v2 encodes "no expiry" as `i64::MAX`; v3's records use `None` for the same concept. Any other value passes through unchanged.

Return true if the time range overlaps with the time range of the given file

Indexes a [`PackedStrings`] # Panic - if the index is beyond the bounds - if the index is not at a UTF-8 character boundary

Push `batches`, a stream of [`RecordBatch`] instances, to object storage. The [`RuntimeEnv`] is utilized if parallelized writes are enabled.

Convert a [StatementParam] value to an InfluxQL [Literal] Will return an error on NULL