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

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


    from f36d2e2  [NEMO-53] Make SchedulingPolicy Stackable (#15)
     add 0745ac5  receive element in BlockStore & refactor partitioner interface
     add 80878f0  Merge remote-tracking branch 'upstream-inc/master' into 
27-ElementWiseWrite
     add d65227d  debug dataskew
     add 46af499  disable concurrent write in Blocks
     add f5e8545  resolve conflict
     add f5103a3  handle block in BlockManagerWorker instead of BlockStore
     add 4b7244f  Merge branch 'master' into 27-ElementWiseWrite
     add da7aa8e  Merge branch 'master' into 27-ElementWiseWrite
     add a88aaf2  Merge branch 'master' into 27-ElementWiseWrite
     add 0ea7451  Merge branch 'master' into 27-ElementWiseWrite
     add 3f22abd  Merge branch '27-ElementWiseWrite' of 
github.com:snuspl/incubator-nemo into 27-ElementWiseWrite
     add 3cf3403  merge pipelining
     add fef3019  minor fix
     add b3d00dc  address comment
     add c68f306  Merge remote-tracking branch 'apache/master' into 
27-ElementWiseWrite
     add fabed6a  address comments
     new 27e2852  Merge pull request #5 from snuspl/27-ElementWiseWrite

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../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(-)
 delete mode 100644 
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data/SerializedPartition.java
 rename runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data/{ => 
partition}/NonSerializedPartition.java (61%)
 rename runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data/{ => 
partition}/Partition.java (67%)
 create mode 100644 
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data/partition/SerializedPartition.java
 delete mode 100644 
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/data/stores/FileStore.java

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

Reply via email to