You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:12:38 UTC
[07/50] incubator-apex-core git commit: Merge pull request #108 from
gauravgopi123/APEX-13-PR1
Merge pull request #108 from gauravgopi123/APEX-13-PR1
APEX-19 APEX-13 #resolve made checkpoint writes asynchronous
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/3c0076a5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/3c0076a5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/3c0076a5
Branch: refs/heads/master
Commit: 3c0076a51be71be4ac0e74e6f5b0d3763a148b3e
Parents: a3e9dfa 29eb6c3
Author: Chetan Narsude <ch...@datatorrent.com>
Authored: Tue Aug 4 17:10:35 2015 -0700
Committer: Chetan Narsude <ch...@datatorrent.com>
Committed: Tue Aug 4 17:10:35 2015 -0700
----------------------------------------------------------------------
.../common/util/AsyncFSStorageAgent.java | 111 ++++++++++++++++
.../datatorrent/common/util/FSStorageAgent.java | 3 +-
.../common/codec/JsonStreamCodecTest.java | 15 ++-
.../common/util/AsyncFSStorageAgentTest.java | 133 +++++++++++++++++++
.../java/com/datatorrent/stram/StramClient.java | 5 +-
.../datatorrent/stram/StramLocalCluster.java | 4 +-
.../stram/StreamingAppMasterService.java | 2 +-
.../stram/StreamingContainerManager.java | 10 +-
.../java/com/datatorrent/stram/engine/Node.java | 64 ++++++++-
.../stram/plan/physical/PhysicalPlan.java | 8 +-
.../com/datatorrent/stram/CheckpointTest.java | 11 +-
.../stram/LogicalPlanModificationTest.java | 22 ++-
.../com/datatorrent/stram/PartitioningTest.java | 26 +++-
.../stram/StramLocalClusterTest.java | 22 ++-
.../datatorrent/stram/StramMiniClusterTest.java | 9 +-
.../datatorrent/stram/StramRecoveryTest.java | 56 ++++++--
.../stram/StreamingContainerManagerTest.java | 45 ++++++-
.../stram/debug/TupleRecorderTest.java | 3 +
.../stram/engine/AutoMetricTest.java | 2 +
.../stram/engine/InputOperatorTest.java | 5 +-
.../stram/engine/ProcessingModeTests.java | 9 ++
.../datatorrent/stram/engine/SliderTest.java | 5 +
.../com/datatorrent/stram/engine/StatsTest.java | 10 +-
.../stram/engine/WindowGeneratorTest.java | 11 +-
.../stram/webapp/StramWebServicesTest.java | 6 +-
25 files changed, 527 insertions(+), 70 deletions(-)
----------------------------------------------------------------------