pub(crate) fn rewrite_source_timestamp(
plan: LogicalPlan,
source_name: &TableReference,
source_timestamp_name: &str,
) -> Result<LogicalPlan, Error>Expand description
Adds the source timestamp to every supported plan node that has to carry it through a filter or projection. The expression is appended only after the visible expressions, so the sink contract remains positional.