Method parse_source_envelope

src/sql-parser/src/parser.rs:2520–2556

(&mut self)

    }

    fn parse_source_envelope(&mut self) -> Result<SourceEnvelope, ParserError> {
        let envelope = if self.parse_keyword(NONE) {
            SourceEnvelope::None
        } else if self.parse_keyword(DEBEZIUM) {
            SourceEnvelope::Debezium
        } else if self.parse_keyword(UPSERT) {
            let value_decode_err_policy = if self.consume_token(&Token::LParen) {
                // We only support the `VALUE DECODING ERRORS` option for now, but if we add another
                // we should extract this into a helper function.
                self.expect_keywords(&[VALUE, DECODING, ERRORS])?;
                let _ = self.consume_token(&Token::Eq);
                let open_inner = self.consume_token(&Token::LParen);
                let value_decode_err_policy =
                    self.parse_comma_separated(Parser::parse_source_error_policy_option)?;
                if open_inner {
                    self.expect_token(&Token::RParen)?;
                }
                self.expect_token(&Token::RParen)?;
                value_decode_err_policy
            } else {
                vec![]
            };

            SourceEnvelope::Upsert {
                value_decode_err_policy,
            }
        } else if self.parse_keyword(MATERIALIZE) {
            SourceEnvelope::CdcV2
        } else {
            return self.expected(
                self.peek_pos(),
                "NONE, UPSERT, or MATERIALIZE",
                self.peek_token(),
            );
        };
        Ok(envelope)
    }

    fn parse_sink_envelope(&mut self) -> Result<SinkEnvelope, ParserError> {
        if self.parse_keyword(UPSERT) {