[incubator-nemo] branch release-v0.2-rc2 updated (798202f -> 708ec11)

[sa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sanha pushed a change to branch release-v0.2-rc2
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git.


 discard 798202f  Merge branch 'master' into release-v0.2-rc2
    omit a7b9cf6  [NEMO-429] SWPP TEAM20 Code Smell Fix (#283)
    omit 0f9fb6c  [NEMO-429] SWPP TEAM 14 code smell fix (#284)

This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.

 * -- * -- N   refs/heads/release-v0.2-rc2 (708ec11)
            \
             O -- O -- O   (798202f)

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

No new revisions were added by this update.

Summary of changes:
 .../nemo/common/coder/LongEncoderFactory.java      |   3 +-
 .../nemo/common/exception/DataSourceException.java |  34 -
 .../beam/transform/PushBackDoFnTransform.java      |   4 +
 .../frontend/spark/coder/SparkDecoderFactory.java  |   5 +-
 .../frontend/spark/coder/SparkEncoderFactory.java  |   5 +-
 .../frontend/spark/core/JavaSparkContext.java      |  26 +-
 .../compiler/frontend/spark/core/SparkContext.java |   8 +-
 .../frontend/spark/core/SparkFrontendUtils.java    |   1 +
 .../frontend/spark/core/rdd/JavaPairRDD.java       | 711 +++++++++++++++++++++
 .../core/rdd/{SparkJavaRDD.java => JavaRDD.java}   | 284 ++++----
 .../frontend/spark/core/rdd/SparkJavaPairRDD.java  | 661 -------------------
 .../source/SparkDatasetBoundedSourceVertex.java    |   1 +
 .../nemo/compiler/frontend/spark/sql/Dataset.java  |  12 +-
 .../compiler/frontend/spark/core/rdd/RDD.scala     |   6 +-
 .../pass/compiletime/annotating/LambdaPass.java    |   5 +-
 .../compiler/backend/nemo/DAGConverterTest.java    |   2 +-
 .../nemo/examples/beam/AlternatingLeastSquare.java |   4 +-
 .../nemo/examples/beam/GenericSourceSink.java      |  19 +-
 .../apache/nemo/examples/spark/JavaMapReduce.java  |  10 +-
 .../apache/nemo/examples/spark/JavaSparkPi.java    |   4 +-
 .../nemo/examples/spark/JavaWordAndLineCount.java  |  16 +-
 .../apache/nemo/examples/spark/JavaWordCount.java  |  12 +-
 .../examples/spark/sql/JavaSparkSQLExample.java    |  24 +-
 .../NativeChannelImplementationSelector.java       |   4 +-
 .../common/message/ncs/NcsMessageContext.java      |   2 +
 .../runtime/executor/data/block/FileBlock.java     |  31 +-
 .../executor/task/SourceVertexDataFetcher.java     |  14 +-
 .../MinOccupancyFirstSchedulingPolicy.java         |   2 +-
 28 files changed, 977 insertions(+), 933 deletions(-)
 delete mode 100644 common/src/main/java/org/apache/nemo/common/exception/DataSourceException.java
 create mode 100644 compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/JavaPairRDD.java
 rename compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/{SparkJavaRDD.java => JavaRDD.java} (52%)
 delete mode 100644 compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaPairRDD.java