Module source_to_iceberg_intermediate_scan_rule 

This rule converts a LogicalSource with an Iceberg connector to a LogicalIcebergIntermediateScan. The intermediate scan node is used to accumulate predicates and column pruning information before being materialized to the final LogicalIcebergScan with delete file anti-joins.

This is the first step in the Iceberg scan optimization pipeline:

1. LogicalSource -> LogicalIcebergIntermediateScan (this rule)
2. Predicate pushdown and column pruning on LogicalIcebergIntermediateScan
3. LogicalIcebergIntermediateScan -> LogicalIcebergScan (materialization rule)

Structs

SourceToIcebergIntermediateScanRule

Functions

fetch_current_snapshot_id 🔒