This is an automated email from the ASF dual-hosted git repository.
zkaoudi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
from 08562c4a Merge pull request #412 from
juripetersen/411-cardinality-repository
add 88dc7ec5 Add spring Scala rest API as a wayang-module
add 25b68a6b Add license headers to scala files
add 8c598076 Add licenses to .properties files
add d44a00a4 Merge pull request #413 from juripetersen/scala-rest-api
No new revisions were added by this update.
Summary of changes:
wayang-api/pom.xml | 1 +
wayang-api/wayang-api-json/pom.xml | 221 +++++++++++++
.../src/main/resources/application.properties} | 2 -
.../wayang-api-json/src/main/resources/plan-a.json | 52 ++++
.../wayang-api-json/src/main/resources/plan-b.json | 53 ++++
.../wayang-api-json/src/main/resources/plan-c.json | 39 +++
.../src/main}/resources/wayang.properties | 3 +-
.../wayang-api-json/src/main/scala/Main.scala | 88 ++++++
.../src/main/scala/builder/JsonPlanBuilder.scala | 344 +++++++++++++++++++++
.../scala/exception/WayangApiJsonException.scala} | 9 +-
.../OperatorFromDrawflow.scala} | 34 +-
.../OperatorFromDrawflowConverter.scala | 126 ++++++++
.../ComposedOperatorFromJson.scala} | 16 +-
.../scala/operatorfromjson/OperatorFromJson.scala | 176 +++++++++++
.../binary/CartesianOperatorFromJson.scala} | 21 +-
.../binary/CoGroupOperatorFromJson.scala} | 38 +--
.../binary/IntersectOperatorFromJson.scala | 36 +--
.../binary/JoinOperatorFromJson.scala} | 38 +--
.../binary/UnionOperatorFromJson.scala} | 35 +--
.../input/InputCollectionFromJson.scala} | 24 +-
.../input/JDBCRemoteInputFromJson.scala | 38 +++
.../input/TableInputFromJson.scala} | 24 +-
.../input/TextFileInputFromJson.scala} | 24 +-
.../loop/DoWhileOperatorFromJson.scala} | 24 +-
.../loop/ForeachOperatorFromJson.scala} | 24 +-
.../loop/RepeatOperatorFromJson.scala} | 24 +-
.../operatorfromjson/other/KMeansFromJson.scala | 43 +++
.../output/TextFileOutputFromJson.scala} | 24 +-
.../unary/CountOperatorFromJson.scala} | 15 +-
.../unary/DistinctOperatorFromJson.scala} | 16 +-
.../unary/FilterOperatorFromJson.scala} | 24 +-
.../unary/FlatMapOperatorFromJson.scala} | 24 +-
.../unary/GroupByOpeartorFromJson.scala} | 33 +-
.../unary/MapOperatorFromJson.scala} | 39 +--
.../unary/MapPartitionsOperatorFromJson.scala} | 24 +-
.../unary/ReduceByOperatorFromJson.scala} | 34 +-
.../unary/ReduceOperatorFromJson.scala} | 24 +-
.../unary/SampleOperatorFromJson.scala} | 40 ++-
.../unary/SortOperatorFromJson.scala} | 24 +-
.../src/main/scala/parserutil/MyTypeName.scala | 21 +-
.../parserutil/ParseOperatorsFromDrawflow.scala | 58 ++++
.../scala/parserutil/ParseOperatorsFromJson.scala | 55 ++++
.../scala/parserutil/ParseScalaFromString.scala | 122 ++++++++
.../scala/springboot/SpringBootApplication.scala} | 13 +-
.../scala/springboot/restapi/WayangApiJson.scala | 82 +++++
.../test/resources/drawflow-composed-plan-a.json | 117 +++++++
.../test/resources/drawflow-composed-plan-b.json | 173 +++++++++++
.../src/test/resources/drawflow-plan-a.json | 133 ++++++++
.../src/test/resources/test-plan-a.json | 68 ++++
.../src/test/resources/test-plan-b.json | 84 +++++
.../wayang.properties | 1 -
wayang-assembly/pom.xml | 5 +
52 files changed, 2448 insertions(+), 362 deletions(-)
create mode 100644 wayang-api/wayang-api-json/pom.xml
copy wayang-api/{wayang-api-scala-java/src/test/resources/wayang.properties =>
wayang-api-json/src/main/resources/application.properties} (96%)
create mode 100644 wayang-api/wayang-api-json/src/main/resources/plan-a.json
create mode 100644 wayang-api/wayang-api-json/src/main/resources/plan-b.json
create mode 100644 wayang-api/wayang-api-json/src/main/resources/plan-c.json
copy wayang-api/{wayang-api-scala-java/src/test =>
wayang-api-json/src/main}/resources/wayang.properties (94%)
create mode 100644 wayang-api/wayang-api-json/src/main/scala/Main.scala
create mode 100644
wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=> wayang-api-json/src/main/scala/exception/WayangApiJsonException.scala} (88%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflow.scala}
(51%)
create mode 100644
wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=>
wayang-api-json/src/main/scala/operatorfromjson/ComposedOperatorFromJson.scala}
(56%)
create mode 100644
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/binary/CartesianOperatorFromJson.scala}
(56%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/binary/CoGroupOperatorFromJson.scala}
(51%)
copy
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/ScrubFunction.scala
=>
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala
(57%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/binary/UnionOperatorFromJson.scala}
(56%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/input/InputCollectionFromJson.scala}
(50%)
create mode 100644
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/JDBCRemoteInputFromJson.scala
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/input/TableInputFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/input/TextFileInputFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/loop/DoWhileOperatorFromJson.scala}
(50%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/loop/ForeachOperatorFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/loop/RepeatOperatorFromJson.scala}
(51%)
create mode 100644
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/other/KMeansFromJson.scala
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/output/TextFileOutputFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/CountOperatorFromJson.scala}
(56%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/DistinctOperatorFromJson.scala}
(56%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/FilterOperatorFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/FlatMapOperatorFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/GroupByOpeartorFromJson.scala}
(52%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/MapOperatorFromJson.scala}
(52%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/MapPartitionsOperatorFromJson.scala}
(50%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/ReduceByOperatorFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/ReduceOperatorFromJson.scala}
(51%)
copy
wayang-api/{wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/SampleOperatorFromJson.scala}
(50%)
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/function/PythonCode.java
=>
wayang-api-json/src/main/scala/operatorfromjson/unary/SortOperatorFromJson.scala}
(51%)
copy
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/operators/test/TestSink.java
=> wayang-api/wayang-api-json/src/main/scala/parserutil/MyTypeName.scala (71%)
create mode 100644
wayang-api/wayang-api-json/src/main/scala/parserutil/ParseOperatorsFromDrawflow.scala
create mode 100644
wayang-api/wayang-api-json/src/main/scala/parserutil/ParseOperatorsFromJson.scala
create mode 100644
wayang-api/wayang-api-json/src/main/scala/parserutil/ParseScalaFromString.scala
copy
wayang-api/{wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=> wayang-api-json/src/main/scala/springboot/SpringBootApplication.scala} (62%)
create mode 100644
wayang-api/wayang-api-json/src/main/scala/springboot/restapi/WayangApiJson.scala
create mode 100644
wayang-api/wayang-api-json/src/test/resources/drawflow-composed-plan-a.json
create mode 100644
wayang-api/wayang-api-json/src/test/resources/drawflow-composed-plan-b.json
create mode 100644
wayang-api/wayang-api-json/src/test/resources/drawflow-plan-a.json
create mode 100644
wayang-api/wayang-api-json/src/test/resources/test-plan-a.json
create mode 100644
wayang-api/wayang-api-json/src/test/resources/test-plan-b.json
copy wayang-api/{wayang-api-scala-java/src/test/resources =>
wayang-api-json}/wayang.properties (96%)
