This is an automated email from the ASF dual-hosted git repository. zkaoudi pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/wayang.git
commit 4d8d5b7d69a8a068a83229b5e9ba1f50be3d052a Merge: 796f1fa69 e6901a312 Author: Zoi Kaoudi <[email protected]> AuthorDate: Wed May 20 09:18:48 2026 +0200 Merge pull request #750 from gknz/feature/jdbc-sql-table-sink Add in-database JdbcTableSinkOperator for SQL-level table writes .gitignore | 1 - .../wayang/genericjdbc/mapping/Mappings.java | 3 +- .../genericjdbc/mapping/TableSinkMapping.java | 59 +++++ .../operators/GenericJdbcTableSinkOperator.java} | 25 +- .../apache/wayang/jdbc/execution/JdbcExecutor.java | 96 +++++++- .../jdbc/operators/JdbcTableSinkOperator.java | 88 +++++++ .../jdbc/execution/JdbcTableSinkExecutorTest.java | 255 +++++++++++++++++++++ .../wayang/jdbc/test/HsqldbTableSinkOperator.java | 69 ++++++ .../apache/wayang/postgres/mapping/Mappings.java | 3 +- .../wayang/postgres/mapping/TableSinkMapping.java | 59 +++++ .../operators/PostgresTableSinkOperator.java} | 25 +- .../apache/wayang/sqlite3/mapping/Mappings.java | 3 +- .../wayang/sqlite3/mapping/TableSinkMapping.java | 59 +++++ .../Sqlite3TableSinkOperator.java} | 31 ++- 14 files changed, 730 insertions(+), 46 deletions(-)
