Module logical_kafka_scan

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.