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 ada6d172c435d26be756ff9e948cf1317130c1b2 Merge: 9bf158082 e42f63fda Author: Zoi Kaoudi <[email protected]> AuthorDate: Mon Aug 17 14:19:06 2026 +0200 Merge pull request #774 from JunWang222/bigquery-engine-platform-only-test Add BigQuery platform with engine-only integration tests bigquery-setup/README.md | 369 +++++++++++++ bigquery-setup/data.yaml | 72 +++ bigquery-setup/demo.sh | 23 + bigquery-setup/docker-compose.yml | 43 ++ bigquery-setup/pom.xml | 79 +++ .../apache/wayang/bigquery/BigQueryEmulatorIT.java | 202 +++++++ demo-bigquery.sh | 95 ++++ pom.xml | 2 +- .../apache/wayang/api/sql/SqlToWayangRelTest.java | 2 +- wayang-platforms/pom.xml | 1 + wayang-platforms/wayang-bigquery/pom.xml | 90 ++++ .../java/org/apache/wayang/bigquery/BigQuery.java | 63 +++ .../org/apache/wayang/bigquery/BigQueryDemo.java | 307 +++++++++++ .../bigquery/channels/ChannelConversions.java | 54 ++ .../wayang/bigquery/mapping/FilterMapping.java | 63 +++ .../bigquery/mapping/GlobalReduceMapping.java | 60 +++ .../wayang/bigquery/mapping/JoinMapping.java | 76 +++ .../apache/wayang/bigquery/mapping/Mappings.java | 41 ++ .../wayang/bigquery/mapping/ProjectionMapping.java | 66 +++ .../wayang/bigquery/mapping/ReduceByMapping.java | 63 +++ .../wayang/bigquery/mapping/SortMapping.java | 62 +++ .../wayang/bigquery/mapping/TableSinkMapping.java | 58 ++ .../operators/BigQueryExecutionOperator.java | 31 ++ .../bigquery/operators/BigQueryFilterOperator.java | 52 ++ .../operators/BigQueryGlobalReduceOperator.java | 50 ++ .../bigquery/operators/BigQueryJoinOperator.java | 49 ++ .../operators/BigQueryProjectionOperator.java | 49 ++ .../operators/BigQueryReduceByOperator.java | 52 ++ .../bigquery/operators/BigQuerySortOperator.java | 49 ++ .../operators/BigQueryTableSinkOperator.java | 48 ++ .../bigquery/operators/BigQueryTableSource.java | 58 ++ .../wayang/bigquery/platform/BigQueryPlatform.java | 62 +++ .../bigquery/plugin/BigQueryConversionsPlugin.java | 58 ++ .../wayang/bigquery/plugin/BigQueryPlugin.java | 58 ++ .../resources/wayang-bigquery-defaults.properties | 188 +++++++ .../wayang/bigquery/BigQueryOperatorsIT.java | 599 +++++++++++++++++++++ .../apache/wayang/jdbc/execution/JdbcExecutor.java | 14 +- .../wayang/jdbc/execution/JdbcExecutorTest.java | 8 +- .../operators/JdbcGlobalReduceOperatorTest.java | 2 +- .../jdbc/operators/JdbcJoinOperatorTest.java | 4 +- .../jdbc/operators/JdbcReduceByOperatorTest.java | 2 +- .../jdbc/operators/JdbcSortOperatorTest.java | 2 +- .../jdbc/JdbcSpatialJoinOperatorTest.java | 6 +- 43 files changed, 3307 insertions(+), 25 deletions(-)
