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.

RegionQueryStatCounters

Query statistic counters owned by a region.

RegionWatermarkEntry

Enums

AsyncRecordBatchStreamAdapterState 🔒

Metrics 🔒

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

Constants

REGION_SCAN_EXEC_NAME 🔒

Functions

collect_full_metrics 🔒

Collects the complete plan metrics used by terminal metrics and verbose analyze output.

collect_lightweight_query_load_metrics 🔒

Collects the minimal metrics needed for query-load reporting before EOF.

collect_lightweight_query_load_metrics_inner 🔒

Recursively walks the physical plan and reads raw metric values without formatting plan nodes.

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.

record_query_stats 🔒

region_scan_output_bytes

Extracts total output_bytes from region scan plan nodes.

Type Aliases

FutureStream 🔒