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 6498d8257c427720b10dd55f9de2ae834ac273c8 Merge: 7d69c0fb1 70a22e161 Author: Zoi Kaoudi <[email protected]> AuthorDate: Thu Aug 6 18:30:09 2026 +0300 Merge pull request #772 from JunWang222/wayang-trino-only-test Add Trino platform with engine-only integration tests platforms-setup-guides/trino-setup/README.md | 282 +++++++++ platforms-setup-guides/trino-setup/demo.sh | 127 ++++ .../trino-setup/docker-compose.yml | 142 +++++ platforms-setup-guides/trino-setup/pom.xml | 95 +++ .../trino-setup/scripts/init.sql | 66 ++ .../trino-setup/scripts/run-init.sh | 40 ++ .../apache/wayang/trino/TrinoIntegrationTest.java | 233 +++++++ .../trino-setup/trino/catalog/iceberg.properties | 32 + .../trino-setup/trino/catalog/tpch.properties | 20 + .../trino-setup/trino/config.properties | 20 + wayang-platforms/pom.xml | 1 + .../operators/JdbcGlobalReduceOperatorTest.java | 22 +- .../jdbc/operators/JdbcJoinOperatorTest.java | 9 +- wayang-platforms/wayang-trino/pom.xml | 86 +++ .../main/java/org/apache/wayang/trino/Trino.java | 63 ++ .../java/org/apache/wayang/trino/TrinoDemo.java | 224 +++++++ .../wayang/trino/channels/ChannelConversions.java | 54 ++ .../apache/wayang/trino/mapping/FilterMapping.java | 63 ++ .../wayang/trino/mapping/GlobalReduceMapping.java | 62 ++ .../apache/wayang/trino/mapping/JoinMapping.java | 76 +++ .../org/apache/wayang/trino/mapping/Mappings.java | 41 ++ .../wayang/trino/mapping/ProjectionMapping.java | 66 ++ .../wayang/trino/mapping/ReduceByMapping.java | 65 ++ .../apache/wayang/trino/mapping/SortMapping.java | 64 ++ .../wayang/trino/mapping/TableSinkMapping.java | 60 ++ .../trino/operators/TrinoExecutionOperator.java | 31 + .../trino/operators/TrinoFilterOperator.java | 52 ++ .../trino/operators/TrinoGlobalReduceOperator.java | 51 ++ .../wayang/trino/operators/TrinoJoinOperator.java | 49 ++ .../trino/operators/TrinoProjectionOperator.java | 49 ++ .../trino/operators/TrinoReduceByOperator.java | 53 ++ .../wayang/trino/operators/TrinoSortOperator.java | 51 ++ .../trino/operators/TrinoTableSinkOperator.java | 51 ++ .../wayang/trino/operators/TrinoTableSource.java | 57 ++ .../wayang/trino/platform/TrinoPlatform.java | 51 ++ .../trino/plugin/TrinoConversionsPlugin.java | 58 ++ .../apache/wayang/trino/plugin/TrinoPlugin.java | 58 ++ .../resources/wayang-trino-defaults.properties | 170 +++++ .../org/apache/wayang/trino/TrinoOperatorsIT.java | 697 +++++++++++++++++++++ 39 files changed, 3476 insertions(+), 15 deletions(-)
