Method parse_sink_envelope

src/sql-parser/src/parser.rs:2558–2566

(&mut self)

    }

    fn parse_sink_envelope(&mut self) -> Result<SinkEnvelope, ParserError> {
        if self.parse_keyword(UPSERT) {
            Ok(SinkEnvelope::Upsert)
        } else if self.parse_keyword(DEBEZIUM) {
            Ok(SinkEnvelope::Debezium)
        } else {
            self.expected(self.peek_pos(), "UPSERT, DEBEZIUM", self.peek_token())
        }
    }

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