Module logical_kafka_scan

risingwave_frontend::optimizer::plan_node

Module logical_kafka_scan 

Source

Structs§

LogicalKafkaScan
LogicalKafkaScan is only used by batch queries. At the beginning of the batch query optimization, LogicalSource with a kafka property would be converted into a LogicalKafkaScan.

Functions§

expr_to_kafka_timestamp_range 🔒
A util function to extract kafka offset timestamp range.