Method monotonic_source

src/adapter/src/optimize/dataflows.rs:445–469

Determine the given source's monotonicity.

(&self, data_source: &DataSourceDesc)

    /// Determine the given source's monotonicity.
    fn monotonic_source(&self, data_source: &DataSourceDesc) -> bool {
        match data_source {
            DataSourceDesc::Ingestion { .. } => false,
            DataSourceDesc::OldSyntaxIngestion {
                desc, data_config, ..
            } => data_config.monotonic(&desc.connection),
            DataSourceDesc::Webhook { .. } => true,
            DataSourceDesc::IngestionExport {
                ingestion_id,
                data_config,
                ..
            } => {
                let source_desc = self
                    .catalog
                    .get_entry_by_item_id(ingestion_id)
                    .source_desc()
                    .expect("ingestion export must reference a source")
                    .expect("ingestion export must reference a source");
                data_config.monotonic(&source_desc.connection)
            }
            DataSourceDesc::Introspection(_)
            | DataSourceDesc::Progress
            | DataSourceDesc::Catalog => false,
        }
    }

    /// Determine the given objects's monotonicity.
    ///