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 7d69c0fb1 Merge pull request #784 from
apache/dependabot/maven/wayang-platforms/wayang-generic-jdbc/org.postgresql-postgresql-42.7.12
add cedc12e31 Add Trino JDBC platform
add 9897efe77 Document Trino platform tests
add 356bfcf32 Implement the Trino operators for JDBC template, add
integration tests into TrinoOperatorsIT
add 88460d31d Document Trino operator integration tests
add f236bf75e Add SQL metadata methods to JavaPlanBuilder operators
add 4b80bec9a Select the left JDBC source for join stages
add aaaba1f33 Add JavaPlanBuilder Trino combination tests
add 38ab7c286 Normalize Trino test comments to ASCII
add 876703196 Update Trino setup docs for full join suite
add 1e207b718 Document Trino macOS and Windows commands
add ccca47ddb Make Trino integration tests engine-only
add a62149d05 Add license headers to Trino setup files
add 92e23ede5 Fix Trino CI license headers and HSQLDB fixture
add 2a6b7926c Ensure JDBC SQL statements end with semicolon
add b55dc943e Update JDBC executor SQL expectations
add 53557adcb Stabilize Tensorflow Iris training shuffle
add 5c3ee9006 Reorganize Trino setup guide files
add 70a22e161 Merge main into Trino PR branch
new 6498d8257 Merge pull request #772 from
JunWang222/wayang-trino-only-test
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:
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 | 27 +-
.../apache/wayang/trino/TrinoIntegrationTest.java | 233 ++++++++++++++
.../trino-setup/trino/catalog/iceberg.properties | 38 +--
.../trino-setup/trino/catalog/tpch.properties | 9 +-
.../trino-setup/trino/config.properties | 7 +-
wayang-platforms/pom.xml | 1 +
.../operators/JdbcGlobalReduceOperatorTest.java | 22 +-
.../jdbc/operators/JdbcJoinOperatorTest.java | 9 +-
.../{wayang-presto => wayang-trino}/pom.xml | 26 +-
.../main/java/org/apache/wayang/trino/Trino.java} | 34 +-
.../java/org/apache/wayang/trino/TrinoDemo.java | 224 +++++++++++++
.../wayang/trino}/channels/ChannelConversions.java | 12 +-
.../wayang/trino}/mapping/FilterMapping.java | 12 +-
.../wayang/trino}/mapping/GlobalReduceMapping.java | 17 +-
.../apache/wayang/trino}/mapping/JoinMapping.java | 12 +-
.../org/apache/wayang/trino}/mapping/Mappings.java | 4 +-
.../wayang/trino}/mapping/ProjectionMapping.java | 12 +-
.../wayang/trino}/mapping/ReduceByMapping.java | 13 +-
.../apache/wayang/trino}/mapping/SortMapping.java | 13 +-
.../wayang/trino}/mapping/TableSinkMapping.java | 12 +-
.../trino/operators/TrinoExecutionOperator.java} | 10 +-
.../trino/operators/TrinoFilterOperator.java} | 14 +-
.../operators/TrinoGlobalReduceOperator.java} | 19 +-
.../wayang/trino/operators/TrinoJoinOperator.java} | 14 +-
.../trino/operators/TrinoProjectionOperator.java} | 16 +-
.../trino/operators/TrinoReduceByOperator.java} | 21 +-
.../wayang/trino/operators/TrinoSortOperator.java} | 18 +-
.../trino/operators/TrinoTableSinkOperator.java} | 23 +-
.../wayang/trino/operators/TrinoTableSource.java} | 13 +-
.../wayang/trino/platform/TrinoPlatform.java} | 20 +-
.../trino/plugin/TrinoConversionsPlugin.java} | 12 +-
.../apache/wayang/trino/plugin/TrinoPlugin.java} | 14 +-
.../resources/wayang-trino-defaults.properties} | 71 +++--
.../org/apache/wayang/trino/TrinoOperatorsIT.java} | 355 ++++++++++++---------
39 files changed, 1658 insertions(+), 411 deletions(-)
create mode 100644 platforms-setup-guides/trino-setup/README.md
create mode 100644 platforms-setup-guides/trino-setup/demo.sh
create mode 100644 platforms-setup-guides/trino-setup/docker-compose.yml
create mode 100644 platforms-setup-guides/trino-setup/pom.xml
create mode 100644 platforms-setup-guides/trino-setup/scripts/init.sql
copy wayang-benchmark/src/main/resources/simplelogger.properties =>
platforms-setup-guides/trino-setup/scripts/run-init.sh (55%)
create mode 100644
platforms-setup-guides/trino-setup/src/test/java/org/apache/wayang/trino/TrinoIntegrationTest.java
copy .github/workflows/todo2issue.yml =>
platforms-setup-guides/trino-setup/trino/catalog/iceberg.properties (56%)
copy wayang-benchmark/src/main/resources/simplelogger.properties =>
platforms-setup-guides/trino-setup/trino/catalog/tpch.properties (79%)
copy wayang-benchmark/src/test/resources/rheem.properties =>
platforms-setup-guides/trino-setup/trino/config.properties (86%)
copy wayang-platforms/{wayang-presto => wayang-trino}/pom.xml (80%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/Postgres.java
=> wayang-trino/src/main/java/org/apache/wayang/trino/Trino.java} (52%)
create mode 100644
wayang-platforms/wayang-trino/src/main/java/org/apache/wayang/trino/TrinoDemo.java
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres =>
wayang-trino/src/main/java/org/apache/wayang/trino}/channels/ChannelConversions.java
(82%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/FilterMapping.java
(85%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/GlobalReduceMapping.java
(84%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/JoinMapping.java
(88%)
copy wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/Mappings.java (91%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/ProjectionMapping.java
(86%)
copy wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/ReduceByMapping.java
(84%)
copy wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/SortMapping.java
(85%)
copy wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto =>
wayang-trino/src/main/java/org/apache/wayang/trino}/mapping/TableSinkMapping.java
(84%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresExecutionOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoExecutionOperator.java}
(76%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresFilterOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoFilterOperator.java}
(73%)
copy
wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto/operators/PrestoGlobalReduceOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoGlobalReduceOperator.java}
(67%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresJoinOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoJoinOperator.java}
(75%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresProjectionOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoProjectionOperator.java}
(68%)
copy
wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto/operators/PrestoReduceByOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoReduceByOperator.java}
(65%)
copy
wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto/operators/PrestoSortOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoSortOperator.java}
(69%)
copy
wayang-platforms/{wayang-presto/src/main/java/org/apache/wayang/presto/operators/PrestoTableSinkOperator.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoTableSinkOperator.java}
(62%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresTableSource.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/operators/TrinoTableSource.java}
(77%)
copy
wayang-platforms/{wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/platform/Sqlite3Platform.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/platform/TrinoPlatform.java}
(69%)
copy
wayang-platforms/{wayang-postgres/src/main/java/org/apache/wayang/postgres/plugin/PostgresConversionsPlugin.java
=>
wayang-trino/src/main/java/org/apache/wayang/trino/plugin/TrinoConversionsPlugin.java}
(82%)
copy
wayang-platforms/{wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/plugin/Sqlite3Plugin.java
=> wayang-trino/src/main/java/org/apache/wayang/trino/plugin/TrinoPlugin.java}
(81%)
copy
wayang-platforms/{wayang-presto/src/main/resources/wayang-presto-defaults.properties
=> wayang-trino/src/main/resources/wayang-trino-defaults.properties} (66%)
copy
wayang-platforms/{wayang-presto/src/test/java/org/apache/wayang/presto/PrestoOperatorsIT.java
=> wayang-trino/src/test/java/org/apache/wayang/trino/TrinoOperatorsIT.java}
(65%)
