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 <[email protected]> Authored: Tue Aug 4 17:10:35 2015 -0700 Committer: Chetan Narsude <[email protected]> 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(-) ----------------------------------------------------------------------
