Structs§
- Logical
Kafka Scan LogicalKafkaScan
is only used by batch queries. At the beginning of the batch query optimization,LogicalSource
with a kafka property would be converted into aLogicalKafkaScan
.
Functions§
- expr_
to_ 🔒kafka_ timestamp_ range - A util function to extract kafka offset timestamp range.