This is an automated email from the ASF dual-hosted git repository.
taegeonum pushed a change to branch license-checkstyle
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git.
from 3e327ac License checkstyle
add 6e2a4db [NEMO-294] Beam-Runner (#163)
add 21e2d90 Merge branch 'master' into license-checkstyle
No new revisions were added by this update.
Summary of changes:
bin/run_beam.sh | 4 +-
bin/run_spark.sh | 4 +-
.../java/org/apache/nemo/client/JobLauncher.java | 163 +++++++++++++--------
compiler/frontend/beam/pom.xml | 13 +-
.../compiler/frontend/beam/NemoPipelineResult.java | 5 +-
.../{NemoPipelineRunner.java => NemoRunner.java} | 32 +++-
.../frontend/beam/NemoRunnerRegistrar.java | 62 ++++++++
.../frontend/spark/core/SparkFrontendUtils.java | 2 +-
.../compiler/frontend/spark/core/rdd/RDD.scala | 2 +-
.../org/apache/nemo/compiler/CompilerTestUtil.java | 3 +-
.../main/java/org/apache/nemo/conf/JobConf.java | 2 +-
.../nemo/examples/beam/AlternatingLeastSquare.java | 4 +-
.../beam/AlternatingLeastSquareInefficient.java | 4 +-
.../org/apache/nemo/examples/beam/Broadcast.java | 4 +-
.../nemo/examples/beam/MinimalWordCount.java | 87 +++++++++++
.../beam/MultinomialLogisticRegression.java | 4 +-
.../nemo/examples/beam/NetworkTraceAnalysis.java | 4 +-
.../nemo/examples/beam/PartitionWordsByLength.java | 4 +-
.../apache/nemo/examples/beam/PerKeyMedian.java | 4 +-
.../nemo/examples/beam/PerPercentileAverage.java | 4 +-
.../apache/nemo/examples/beam/SimpleSumSQL.java | 4 +-
.../nemo/examples/beam/WindowedBroadcast.java | 4 +-
.../nemo/examples/beam/WindowedWordCount.java | 4 +-
.../org/apache/nemo/examples/beam/WordCount.java | 4 +-
pom.xml | 1 +
25 files changed, 327 insertions(+), 101 deletions(-)
rename
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/{NemoPipelineRunner.java
=> NemoRunner.java} (67%)
create mode 100644
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/NemoRunnerRegistrar.java
create mode 100644
examples/beam/src/main/java/org/apache/nemo/examples/beam/MinimalWordCount.java
