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 <[email protected]> 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(-)
