Method parse_create_iceberg_sink

src/sql-parser/src/parser.rs:3476–3510

(
        &mut self,
        name: Option<UnresolvedItemName>,
        in_cluster: Option<RawClusterName>,
        from: RawItemName,
        if_not_exists: bool,
        connection: CreateSinkConnect

    }

    fn parse_create_iceberg_sink(
        &mut self,
        name: Option<UnresolvedItemName>,
        in_cluster: Option<RawClusterName>,
        from: RawItemName,
        if_not_exists: bool,
        connection: CreateSinkConnection<Raw>,
    ) -> Result<CreateSinkStatement<Raw>, ParserError> {
        let mode = if self.parse_keyword(MODE) {
            Some(self.parse_iceberg_sink_mode()?)
        } else {
            None
        };

        let with_options = if self.parse_keyword(WITH) {
            self.expect_token(&Token::LParen)?;
            let options = self.parse_comma_separated(Parser::parse_create_sink_option)?;
            self.expect_token(&Token::RParen)?;
            options
        } else {
            vec![]
        };

        Ok(CreateSinkStatement {
            name,
            in_cluster,
            from,
            connection,
            format: None,
            envelope: None,
            mode,
            if_not_exists,
            with_options,
        })
    }

    fn parse_create_kafka_sink(
        &mut self,