Function apply_watermark_after_ingest 

pub fn apply_watermark_after_ingest(
    ds: DataSet,
    schema: &Schema,
    options: &IngestionOptions,
) -> IngestionResult<DataSet>

Apply watermark filtering when options request it (call after validate_watermark_config).