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 a2f5ed71 Merge pull request #467 from juripetersen/fix-flink-versioning
add a7afeee4 renamed examples to applications
add dfe309ac finished WordCount with KafkaSource and KafkaSink
add 00bc4225 fixed license issue
add a7397892 changes scope and systempath in dependency on
wayang-api-scala-java_2.12 in wayang-applications so that it can be build in
cloud env. MIGHT BRING BACK THE VISIBILITY ISSUE ! -> must be checked
add ad39d7fe fixed version conflict with 2.12 versions of Wayang-packages.
add 79ad6958 deactivated the tests, which break the cloud build.
add 9f4ee35f fixed review issues
add 6f21676c added license note.
add c73578a8 clean files
add bc507955 removed debugging line from wayang-submit
add 953873e7 added another test application to support debugging.
add 9d9d7755 cleaned the bootstrap and clean scripts in
wayang-applications.
add df588e2b configuration for kafka cluster has been parametrized using
env.sh file
add b2fee627 fixed license header.
add a0e260a5 added Readme and removed brew related comments.
add e7b268a4 clean env_template.sh
add 6353814a make version in env_template.sh configurable
add 3caf1bb5 removed OSX specific paths
add d86eeb3d Rename env_template.sh to env_template_osx.sh
add d245a36b Update README.md
add b95e18c7 Merge branch 'kamir-patch-2' of
https://github.com/apache/incubator-wayang into kamir-patch-2
add 886938e6 Merge pull request #468 from apache/kamir-patch-2
No new revisions were added by this update.
Summary of changes:
bin/wayang-submit | 3 +-
.../pywayang_config.ini => env_template_osx.sh | 39 +++---
pom.xml | 7 +-
.../scala/org/apache/wayang/api/DataQuanta.scala | 4 +-
wayang-applications/README.md | 60 +++++++++
.../bin/bootstrap_ccloud_kafka_topics.sh | 35 ++++++
.../bin/cleanup_ccloud_kafka_topics.sh | 17 +--
.../bin/env.demo1.sh | 11 +-
.../bin/env_template.sh | 36 +++---
.../bin/run_wordcount.sh | 28 ++---
.../bin/run_wordcount_kafka.sh | 29 ++---
.../data/case-study/DATA_REPO_001/README.md | 0
wayang-applications/pom.xml | 134 +++++++++++++++++++++
.../wayang/applications/OutputSerializer.java | 22 ++--
.../java/org/apache/wayang/applications/Util.java | 11 +-
.../org/apache/wayang/applications}/WordCount.java | 52 ++++----
.../wayang/applications/WordCountOnKafkaTopic.java | 126 +++++++++++++++++++
wayang-assembly/dependency-reduced-pom.xml | 2 +-
.../wayang/basic/operators/KafkaTopicSink.java | 1 +
.../wayang/java/operators/JavaKafkaTopicSink.java | 23 ++--
...leSinkTest.java => JavaKafkaTopicSinkTest.java} | 108 ++++++++++++-----
.../java/operators/JavaKafkaTopicSourceTest.java | 9 +-
.../java/operators/JavaTextFileSinkTest.java | 9 +-
.../spark/operators/SparkKafkaTopicSource.java | 2 +-
24 files changed, 592 insertions(+), 176 deletions(-)
copy python/old_code/pywayang/src/pywy/config/pywayang_config.ini =>
env_template_osx.sh (55%)
mode change 100644 => 100755
create mode 100644 wayang-applications/README.md
create mode 100755 wayang-applications/bin/bootstrap_ccloud_kafka_topics.sh
copy python/src/pywy/execution/util.py =>
wayang-applications/bin/cleanup_ccloud_kafka_topics.sh (63%)
mode change 100644 => 100755
copy python/old_code/pywayang/src/pywy/config/__init__.py =>
wayang-applications/bin/env.demo1.sh (77%)
copy python/old_code/pywayang/src/pywy/config/pywayang_config.ini =>
wayang-applications/bin/env_template.sh (59%)
copy python/old_code/pywayang/src/pywy/config/pywayang_config.ini =>
wayang-applications/bin/run_wordcount.sh (65%)
mode change 100644 => 100755
copy python/old_code/pywayang/src/pywy/config/pywayang_config.ini =>
wayang-applications/bin/run_wordcount_kafka.sh (67%)
mode change 100644 => 100755
copy README.md => wayang-applications/data/case-study/DATA_REPO_001/README.md
(100%)
create mode 100644 wayang-applications/pom.xml
copy
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/AddIdFunction.scala
=>
wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java
(72%)
copy
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/Model.java
=> wayang-applications/src/main/java/org/apache/wayang/applications/Util.java
(80%)
copy {wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount =>
wayang-applications/src/main/java/org/apache/wayang/applications}/WordCount.java
(62%)
create mode 100644
wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java
copy
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/{JavaTextFileSinkTest.java
=> JavaKafkaTopicSinkTest.java} (51%)
