You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@wayang.apache.org by zk...@apache.org on 2026/05/20 07:18:55 UTC

(wayang) 01/01: Merge pull request #750 from gknz/feature/jdbc-sql-table-sink

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 <zk...@users.noreply.github.com>
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(-)