You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by al...@apache.org on 2023/04/16 08:49:48 UTC
[incubator-wayang] branch main updated (d495e10c -> d46f3c3f)
This is an automated email from the ASF dual-hosted git repository.
aloalt pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
from d495e10c Merge pull request #277 from apache/dependabot/maven/wayang-commons/org.yaml-snakeyaml-2.0
new 8880ec7d Initial version of the SQL API
new e314a190 Fixed license headers
new 326b740f fixed spark dependency
new 3134bd48 cleanup license header
new fcf91996 Fixed license issues
new d46f3c3f Merge pull request #284 from kbeedkar/sql-dev
The 1660 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:
wayang-api/pom.xml | 1 +
wayang-api/wayang-api-sql/pom.xml | 90 ++++
.../sql/calcite/convention/WayangConvention.java | 50 +-
.../sql/calcite/converter/WayangFilterVisitor.java | 165 ++++++
.../sql/calcite/converter/WayangJoinVisitor.java | 24 +-
.../calcite/converter/WayangProjectVisitor.java | 103 ++++
.../sql/calcite/converter/WayangRelConverter.java | 36 +-
.../calcite/converter/WayangRelNodeVisitor.java | 20 +-
.../calcite/converter/WayangTableScanVisitor.java | 68 +++
.../wayang/api/sql/calcite/jdbc/JdbcSchema.java | 557 +++++++++++++++++++++
.../wayang/api/sql/calcite/jdbc/JdbcTable.java | 234 +++++++++
.../wayang/api/sql/calcite/jdbc/JdbcUtils.java | 271 ++++++++++
.../api/sql/calcite/optimizer/Optimizer.java | 242 +++++++++
.../api/sql/calcite/optimizer/WayangProgram.java | 54 ++
.../wayang/api/sql/calcite/rel/WayangFilter.java | 47 ++
.../wayang/api/sql/calcite/rel/WayangJoin.java | 59 +++
.../wayang/api/sql/calcite/rel/WayangProject.java | 53 ++
.../wayang/api/sql/calcite/rel/WayangRel.java | 25 +
.../api/sql/calcite/rel/WayangTableScan.java | 95 ++++
.../wayang/api/sql/calcite/rules/WayangRules.java | 179 +++++++
.../wayang/api/sql/calcite/schema/SchemaUtils.java | 99 ++++
.../api/sql/calcite/schema/WayangSchema.java | 51 ++
.../sql/calcite/schema/WayangSchemaBuilder.java | 55 ++
.../wayang/api/sql/calcite/schema/WayangTable.java | 71 +++
.../api/sql/calcite/schema/WayangTableBuilder.java | 76 +++
.../sql/calcite/schema/WayangTableStatistic.java | 67 +++
.../wayang/api/sql/calcite/utils/PrintUtils.java | 60 +++
.../apache/wayang/api/sql/context/SqlContext.java | 119 +++++
.../wayang/api/sql/sources/fs/CsvRowConverter.java | 167 ++++++
.../api/sql/sources/fs/JavaCSVTableSource.java | 201 ++++++++
.../src/main/resources/log4j.properties | 17 +-
.../java/org/apache/wayang/api/sql/SqlAPI.java | 111 ++++
.../java/org/apache/wayang/api/sql/SqlTest.java | 96 ++++
.../apache/wayang/api/sql/SqlToWayangRelTest.java | 130 +++++
.../src/test/resources/log4j.properties | 17 +-
35 files changed, 3634 insertions(+), 76 deletions(-)
create mode 100644 wayang-api/wayang-api-sql/pom.xml
copy wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/Constant.java => wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/convention/WayangConvention.java (50%)
mode change 100644 => 100755
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java
copy wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExtendedFunction.java => wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java (69%)
mode change 100644 => 100755
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java
copy wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorMatch.java => wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java (51%)
mode change 100644 => 100755
copy wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExtendedFunction.java => wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java (70%)
mode change 100644 => 100755
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcSchema.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcTable.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcUtils.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/WayangProgram.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangFilter.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangJoin.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangProject.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangRel.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangTableScan.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/SchemaUtils.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangSchema.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangSchemaBuilder.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTable.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTableBuilder.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTableStatistic.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/PrintUtils.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java
create mode 100755 wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java
copy wayang-commons/wayang-core/src/test/resources/partial-plugin.yaml => wayang-api/wayang-api-sql/src/main/resources/log4j.properties (70%)
mode change 100644 => 100755
create mode 100755 wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlAPI.java
create mode 100755 wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlTest.java
create mode 100755 wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlToWayangRelTest.java
copy wayang-commons/wayang-core/src/test/resources/partial-plugin.yaml => wayang-api/wayang-api-sql/src/test/resources/log4j.properties (70%)
mode change 100644 => 100755