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 23033b223f2ea263711077bdeef48be3ee006aef
Merge: 83d281d9c dbb920808
Author: Zoi Kaoudi <[email protected]>
AuthorDate: Wed Jun 10 21:11:16 2026 +0200

    Merge pull request #708 from mohit-devlogs/jdbc-join-operator
    
    Add Join operator support for Generic JDBC platform

 wayang-platforms/wayang-generic-jdbc/pom.xml       |   7 ++
 .../genericjdbc/execution/GenericJdbcExecutor.java |   9 +-
 .../wayang/genericjdbc/mapping/JoinMapping.java    |  70 +++++++++++
 .../wayang/genericjdbc/mapping/Mappings.java       |   3 +
 .../operators/GenericJdbcJoinOperator.java         |  47 +++++++
 .../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           |  30 +++++
 .../apache/wayang/jdbc/execution/JdbcExecutor.java |  84 ++++++++-----
 12 files changed, 540 insertions(+), 100 deletions(-)

Reply via email to