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
