You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by ju...@apache.org on 2025/04/15 08:00:22 UTC
(incubator-wayang) branch main updated (91573ae1 -> 4ae6d737)
This is an automated email from the ASF dual-hosted git repository.
juri pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
from 91573ae1 Merge pull request #544 from mspruc/main
add b492961b clean up and change structure
add 48b2fc1d fix up some inaccurate tests
add 8266439e move filter functions to own class
add a75a96ae restructure project, move func to own class
add b42c8cfa cleanup & formatting
add f09522e2 licenses
add 166022bd add filters w. where clauses for java platforms in sql-api
new 4ae6d737 Merge pull request #546 from mspruc/main
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:
.../calcite/converter/WayangAggregateVisitor.java | 1 -
.../calcite/converter/WayangCrossJoinVisitor.java | 4 +-
.../sql/calcite/converter/WayangFilterVisitor.java | 108 +----------------
.../sql/calcite/converter/WayangJoinVisitor.java | 125 ++++++-------------
.../converter/WayangMultiConditionJoinVisitor.java | 6 +-
.../calcite/converter/WayangProjectVisitor.java | 125 ++-----------------
.../sql/calcite/converter/WayangRelConverter.java | 1 +
.../calcite/converter/WayangRelNodeVisitor.java | 1 +
.../calcite/converter/WayangTableScanVisitor.java | 1 +
.../converter/functions/AggregateFunction.java | 11 +-
.../functions/FilterEvaluateCondition.java | 135 +++++++++++++++++++++
...eKeyExtractor.java => FilterPredicateImpl.java} | 25 ++--
...attenJoinResult.java => JoinFlattenResult.java} | 2 +-
...gateKeyExtractor.java => JoinKeyExtractor.java} | 20 +--
.../ProjectMapFuncImpl.java} | 115 ++++++------------
.../apache/wayang/api/sql/SqlToWayangRelTest.java | 49 ++++++--
.../src/test/resources/data/exampleRefToRef.csv | 2 +-
17 files changed, 290 insertions(+), 441 deletions(-)
create mode 100644 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java
copy wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/{AggregateKeyExtractor.java => FilterPredicateImpl.java} (64%)
rename wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/{FlattenJoinResult.java => JoinFlattenResult.java} (96%)
copy wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/{AggregateKeyExtractor.java => JoinKeyExtractor.java} (67%)
copy wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/{WayangProjectVisitor.java => functions/ProjectMapFuncImpl.java} (51%)
mode change 100755 => 100644
(incubator-wayang) 01/01: Merge pull request #546 from mspruc/main
Posted by ju...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
juri pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 4ae6d73702c0acec8cc1b2804ca68b732c153cdf
Merge: 91573ae1 166022bd
Author: Juri Petersen <43...@users.noreply.github.com>
AuthorDate: Tue Apr 15 10:00:18 2025 +0200
Merge pull request #546 from mspruc/main
Restructure visitors & add filters w. where clauses for sql-api
.../calcite/converter/WayangAggregateVisitor.java | 1 -
.../calcite/converter/WayangCrossJoinVisitor.java | 4 +-
.../sql/calcite/converter/WayangFilterVisitor.java | 108 +----------------
.../sql/calcite/converter/WayangJoinVisitor.java | 125 ++++++-------------
.../converter/WayangMultiConditionJoinVisitor.java | 6 +-
.../calcite/converter/WayangProjectVisitor.java | 125 ++-----------------
.../sql/calcite/converter/WayangRelConverter.java | 1 +
.../calcite/converter/WayangRelNodeVisitor.java | 1 +
.../calcite/converter/WayangTableScanVisitor.java | 1 +
.../converter/functions/AggregateFunction.java | 11 +-
.../functions/FilterEvaluateCondition.java | 135 +++++++++++++++++++++
.../FilterPredicateImpl.java} | 22 ++--
...attenJoinResult.java => JoinFlattenResult.java} | 2 +-
.../JoinKeyExtractor.java} | 19 +--
.../ProjectMapFuncImpl.java} | 115 ++++++------------
.../apache/wayang/api/sql/SqlToWayangRelTest.java | 49 ++++++--
.../src/test/resources/data/exampleRefToRef.csv | 2 +-
17 files changed, 297 insertions(+), 430 deletions(-)