Merge branch 'APEXCORE-448' of https://github.com/chandnisingh/incubator-apex-core into APEXCORE-448
Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/3119aba8 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/3119aba8 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/3119aba8 Branch: refs/heads/master Commit: 3119aba891676d936c76cd36acf5fb6833547a13 Parents: a42c67b 9bcde2e Author: Vlad Rozov <[email protected]> Authored: Tue Aug 16 12:42:02 2016 -0700 Committer: Vlad Rozov <[email protected]> Committed: Tue Aug 16 12:42:02 2016 -0700 ---------------------------------------------------------------------- .../main/java/com/datatorrent/api/Context.java | 5 ++ .../stram/api/OperatorDeployInfo.java | 6 ++ .../stram/engine/OperatorContext.java | 15 +++- .../stram/engine/StreamingContainer.java | 5 +- .../stram/engine/AtMostOnceTest.java | 3 +- .../stram/engine/GenericNodeTest.java | 14 ++-- .../datatorrent/stram/engine/InputNodeTest.java | 2 +- .../com/datatorrent/stram/engine/NodeTest.java | 13 ++-- .../stram/engine/OperatorContextTest.java | 79 ++++++++++++++++++++ .../stram/engine/ProcessingModeTests.java | 2 +- .../stram/stream/InlineStreamTest.java | 6 +- 11 files changed, 130 insertions(+), 20 deletions(-) ----------------------------------------------------------------------
