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 83d281d9c Merge pull request #740 from
empeje/empeje/add-documentation-on-execution-plan
add a474b5dac Wayang-707 Add Generic JDBC Join operator
add b2f338758 Add unit test for GenericJdbcJoinOperator
add a718bfd90 Fix GenericJdbcTableSource jdbcName handling causing
incorrect configuration lookup
add 921d3f875 Fix GenericJdbcJoinOperatorTest and
GenericJdbcFilterOperatorTest SQL execution pipeline
add 56b9bc2ac Address review comments
add ebe526bb3 Merge branch 'main' into jdbc-join-operator
add 14d9d7f27 Merge remote-tracking branch 'upstream/main' into
jdbc-join-operator
add dbb920808 Fix GenericJdbc tests by providing JDBC configuration
new 23033b223 Merge pull request #708 from mohit-devlogs/jdbc-join-operator
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:
wayang-platforms/wayang-generic-jdbc/pom.xml | 7 ++
.../genericjdbc/execution/GenericJdbcExecutor.java | 9 +-
.../{FilterMapping.java => JoinMapping.java} | 29 +++--
.../wayang/genericjdbc/mapping/Mappings.java | 3 +
.../operators/GenericJdbcJoinOperator.java} | 28 ++---
.../operators/GenericJdbcTableSource.java | 40 +++---
.../operators/GenericSqlToStreamOperator.java | 84 ++++++-------
.../genericjdbc/platform/GenericJdbcPlatform.java | 2 +-
.../operators/GenericJdbcFilterOperatorTest.java | 127 +++++++++++++++++++
.../operators/GenericJdbcJoinOperatorTest.java | 137 +++++++++++++++++++++
.../src/test/resources}/wayang.properties | 22 ++--
.../apache/wayang/jdbc/execution/JdbcExecutor.java | 84 ++++++++-----
12 files changed, 436 insertions(+), 136 deletions(-)
copy
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/{FilterMapping.java
=> JoinMapping.java} (69%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresJoinOperator.java
=>
wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcJoinOperator.java}
(62%)
create mode 100644
wayang-platforms/wayang-generic-jdbc/src/test/java/org/apache/wayang/genericjdbc/operators/GenericJdbcFilterOperatorTest.java
create mode 100644
wayang-platforms/wayang-generic-jdbc/src/test/java/org/apache/wayang/genericjdbc/operators/GenericJdbcJoinOperatorTest.java
copy {tools/test/config =>
wayang-platforms/wayang-generic-jdbc/src/test/resources}/wayang.properties (59%)
mode change 100755 => 100644
