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

jeongyoon pushed a change to branch 717-TGE
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git.


    from 7bde45c  PipeImpl to LocalPipe
     add 8752b95  remove extra per-element operation
     add b6d03b5  Pipe to OutputCollector

No new revisions were added by this update.

Summary of changes:
 .../common/ir/{Pipe.java => OutputCollector.java}  |   2 +-
 .../common/ir/vertex/transform/RelayTransform.java |  12 +-
 .../nemo/common/ir/vertex/transform/Transform.java |   6 +-
 .../beam/transform/CreateViewTransform.java        |  10 +-
 .../frontend/beam/transform/DoTransform.java       |  32 +-
 .../frontend/beam/transform/FlattenTransform.java  |  10 +-
 .../beam/transform/GroupByKeyTransform.java        |  10 +-
 .../frontend/beam/transform/WindowTransform.java   |  10 +-
 .../frontend/spark/transform/CollectTransform.java |   4 +-
 .../frontend/spark/transform/FlatMapTransform.java |  10 +-
 .../spark/transform/GroupByKeyTransform.java       |  10 +-
 .../spark/transform/MapToPairTransform.java        |  10 +-
 .../frontend/spark/transform/MapTransform.java     |  10 +-
 .../spark/transform/ReduceByKeyTransform.java      |  10 +-
 .../frontend/spark/transform/ReduceTransform.java  |  10 +-
 .../optimizer/examples/EmptyComponents.java        |   4 +-
 .../nemo/runtime/executor/TaskGroupExecutor.java   | 328 +++++++++------------
 .../{LocalPipe.java => OutputCollectorImpl.java}   |  24 +-
 .../executor/datatransfer/TaskDataHandler.java     |  94 ++++++
 .../runtime/executor/TaskGroupExecutorTest.java    |  13 +-
 20 files changed, 334 insertions(+), 285 deletions(-)
 rename common/src/main/java/edu/snu/nemo/common/ir/{Pipe.java => 
OutputCollector.java} (95%)
 rename 
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/{LocalPipe.java
 => OutputCollectorImpl.java} (73%)
 create mode 100644 
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/TaskDataHandler.java

-- 
To stop receiving notification emails like this one, please contact
jeongy...@apache.org.

Reply via email to