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
