Skip to main content

validate_watermark_config

rust_data_processing::ingestion::watermark

Function validate_watermark_config 

Source 
pub fn validate_watermark_config(
    schema: &Schema,
    options: &IngestionOptions,
) -> IngestionResult<()>
Expand description

Ensure watermark options are consistent with schema and with each other.