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
• RecordBatchStreamTypeAdapter
  Casts the RecordBatches of stream against the output_schema.

Enums

• AsyncRecordBatchStreamAdapterState 🔒
• Metrics 🔒
  Json encoded metrics. Contains metric from a whole plan tree.

Type Aliases

• FutureStream 🔒