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

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 🔒