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

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

commit 27e2852169f291dccf53159747254c86c5768367
Merge: f36d2e2 fabed6a
Author: Jeongyoon Eo <jeongyoon0...@gmail.com>
AuthorDate: Fri May 18 13:11:45 2018 +0900

    Merge pull request #5 from snuspl/27-ElementWiseWrite
    
    [NEMO-27] Element Wise Block Write

 .../edu/snu/nemo/common/test/ExampleTestUtil.java  |  30 +--
 .../reshaping/DataSkewReshapingPass.java           |   4 +-
 .../beam/AlternatingLeastSquareITCase.java         |   7 +-
 .../snu/nemo/examples/beam/BroadcastITCase.java    |   7 +-
 .../snu/nemo/examples/beam/MapReduceITCase.java    |   7 +-
 .../edu/snu/nemo/examples/spark/SparkITCase.java   |   7 +-
 .../runtime/common/optimizer/RuntimeOptimizer.java |  10 +-
 .../pass/runtime/DataSkewRuntimePass.java          |  53 ++--
 runtime/common/src/main/proto/ControlMessage.proto |   7 +-
 .../nemo/runtime/executor/TaskGroupExecutor.java   |   5 +-
 .../executor/bytetransfer/ByteOutputContext.java   |   2 +-
 .../runtime/executor/data/BlockManagerWorker.java  | 144 ++++++-----
 .../snu/nemo/runtime/executor/data/DataUtil.java   |  13 +-
 .../runtime/executor/data/SerializedPartition.java |  84 ------
 .../nemo/runtime/executor/data/block/Block.java    |  74 ++++--
 .../runtime/executor/data/block/FileBlock.java     | 281 +++++++++++++++------
 .../data/block/NonSerializedMemoryBlock.java       | 129 +++++++---
 .../executor/data/block/SerializedMemoryBlock.java | 153 ++++++++---
 .../executor/data/metadata/FileMetadata.java       |  15 +-
 .../executor/data/metadata/RemoteFileMetadata.java |   2 +-
 .../{ => partition}/NonSerializedPartition.java    |  70 +++--
 .../executor/data/{ => partition}/Partition.java   |  21 +-
 .../data/partition/SerializedPartition.java        | 175 +++++++++++++
 .../data/partitioner/DataSkewHashPartitioner.java  |  56 ++--
 .../executor/data/partitioner/HashPartitioner.java |  40 ++-
 .../data/partitioner/IntactPartitioner.java        |  17 +-
 .../executor/data/partitioner/Partitioner.java     |  20 +-
 .../executor/data/stores/AbstractBlockStore.java   |   2 +-
 .../runtime/executor/data/stores/BlockStore.java   | 108 ++------
 .../runtime/executor/data/stores/FileStore.java    |  36 ---
 .../executor/data/stores/GlusterFileStore.java     | 142 ++---------
 .../executor/data/stores/LocalBlockStore.java      | 104 +-------
 .../executor/data/stores/LocalFileStore.java       |  56 ++--
 .../runtime/executor/data/stores/MemoryStore.java  |  29 ++-
 .../executor/data/stores/RemoteFileStore.java      |   2 +-
 .../data/stores/SerializedMemoryStore.java         |  28 +-
 .../runtime/executor/datatransfer/InputReader.java |   2 -
 .../executor/datatransfer/OutputWriter.java        | 200 +++++----------
 .../edu/snu/nemo/runtime/master/RuntimeMaster.java |  23 +-
 .../pass/runtime/DataSkewRuntimePassTest.java      |  30 ++-
 .../runtime/executor/TaskGroupExecutorTest.java    |   2 +-
 .../runtime/executor/data/BlockStoreTest.java      | 100 ++++----
 .../executor/datatransfer/DataTransferTest.java    |   9 +-
 43 files changed, 1243 insertions(+), 1063 deletions(-)

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

Reply via email to