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