Module adapter 

Structs

AsyncRecordBatchStreamAdapter

DfRecordBatchStreamAdapter

Greptime SendableRecordBatchStream -> DataFusion RecordBatchStream. The reverse one is RecordBatchStreamAdapter.

MetricCollector

An [ExecutionPlanVisitor] to collect metrics from a [ExecutionPlan].

PlanMetrics

RecordBatchMetrics

RecordBatchMetrics carrys metrics value from datanode to frontend through gRPC

RecordBatchStreamAdapter

DataFusion SendableRecordBatchStream -> Greptime RecordBatchStream. The reverse one is DfRecordBatchStreamAdapter. It can collect metrics from DataFusion execution plan.

RecordBatchStreamTypeAdapter

Casts the RecordBatches of stream against the output_schema.

Enums

AsyncRecordBatchStreamAdapterState 🔒

Metrics 🔒

Json encoded metrics. Contains metric from a whole plan tree.

Functions

convert_map_to_json_binary 🔒

Convert a Map array to a Binary array containing JSON data

custom_cast 🔒

Custom cast function that handles Map -> Binary (JSON) conversion

format_bytes_human_readable 🔒

is_bytes_metric 🔒

Determines if a metric name represents a bytes measurement that should be formatted.

is_time_metric 🔒

Determines if a metric name represents a time measurement that should be formatted.

one_line 🔒

Returns a single-line summary of the root of the plan. If the verbose flag is set, it will display detailed information about the plan.

Type Aliases

FutureStream 🔒