MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / parse_iceberg_sink_mode

Method parse_iceberg_sink_mode

src/sql-parser/src/parser.rs:2568–2576  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

2566 }
2567
2568 fn parse_iceberg_sink_mode(&mut self) -> Result<IcebergSinkMode, ParserError> {
2569 if self.parse_keyword(UPSERT) {
2570 Ok(IcebergSinkMode::Upsert)
2571 } else if self.parse_keyword(APPEND) {
2572 Ok(IcebergSinkMode::Append)
2573 } else {
2574 self.expected(self.peek_pos(), "UPSERT, APPEND", self.peek_token())
2575 }
2576 }
2577
2578 /// Parse a `VALIDATE` statement
2579 fn parse_validate(&mut self) -> Result<Statement<Raw>, ParserError> {

Callers 1

Calls 4

parse_keywordMethod · 0.80
expectedMethod · 0.80
peek_posMethod · 0.80
peek_tokenMethod · 0.80

Tested by

no test coverage detected