This is an automated email from the ASF dual-hosted git repository.
zkaoudi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/wayang.git
from 796f1fa69 Merge pull request #715 from
Zeyad-Hassan-1/fix/issue-632-tuple-types
add 441866dff Add in-database JdbcTableSinkOperator for SQL-level table
writes
add e6901a312 Add tests for JdbcTableSinkOperator and createSqlSuffix
extension point
new 4d8d5b7d6 Merge pull request #750 from gknz/feature/jdbc-sql-table-sink
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 1 -
.../wayang/genericjdbc/mapping/Mappings.java | 3 +-
.../genericjdbc}/mapping/TableSinkMapping.java | 19 +-
.../operators/GenericJdbcTableSinkOperator.java | 21 +-
.../apache/wayang/jdbc/execution/JdbcExecutor.java | 96 +++++++-
.../jdbc/operators/JdbcTableSinkOperator.java | 88 +++++++
.../jdbc/execution/JdbcTableSinkExecutorTest.java | 255 +++++++++++++++++++++
...bleSource.java => HsqldbTableSinkOperator.java} | 39 ++--
.../apache/wayang/postgres/mapping/Mappings.java | 3 +-
.../wayang/postgres}/mapping/TableSinkMapping.java | 19 +-
.../operators/PostgresTableSinkOperator.java | 21 +-
.../apache/wayang/sqlite3/mapping/Mappings.java | 3 +-
.../wayang/sqlite3}/mapping/TableSinkMapping.java | 19 +-
...Operator.java => Sqlite3TableSinkOperator.java} | 18 +-
14 files changed, 524 insertions(+), 81 deletions(-)
copy wayang-platforms/{wayang-java/src/main/java/org/apache/wayang/java =>
wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc}/mapping/TableSinkMapping.java
(75%)
copy
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java
=>
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcTableSinkOperator.java
(60%)
create mode 100644
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcTableSinkOperator.java
create mode 100644
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/execution/JdbcTableSinkExecutorTest.java
copy
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/test/{HsqldbTableSource.java
=> HsqldbTableSinkOperator.java} (58%)
copy wayang-platforms/{wayang-java/src/main/java/org/apache/wayang/java =>
wayang-postgres/src/main/java/org/apache/wayang/postgres}/mapping/TableSinkMapping.java
(75%)
copy
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java
=>
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresTableSinkOperator.java
(61%)
copy wayang-platforms/{wayang-java/src/main/java/org/apache/wayang/java =>
wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3}/mapping/TableSinkMapping.java
(75%)
copy
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/{Sqlite3FilterOperator.java
=> Sqlite3TableSinkOperator.java} (68%)
