Biasqo opened a new pull request, #171: URL: https://github.com/apache/flink-connector-jdbc/pull/171
🔌 ClickHouse Dialect for Flink Link JDBC Connector This project provides a ClickHouse SQL dialect implementation for the Apache Flink JDBC Connector. 🚀 Purpose Apache Flink’s Link JDBC connector offers a flexible way to integrate with relational databases through dialects. However, native support for ClickHouse’s SQL features (e.g. merge trees, upserts, batch writes) is limited in SQL CLI. ✨ Features ✅ Custom ClickHouseDialect integration ✅ Column quoting and identifier case sensitivity fixes ✅ Insert/update query support tailored for ClickHouse (pkFields removed from update statement) TODO: Refactor Tests: Some methods are private (like getStreamFields() that's why I had to recreate some test classes) Jira Issue: https://issues.apache.org/jira/projects/FLINK/issues/FLINK-37834 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
