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 🔒