STREAMS-198 | Merged STREAMS-197 pull request
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/4f2e3cf2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/4f2e3cf2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/4f2e3cf2 Branch: refs/heads/master Commit: 4f2e3cf2ebd7c8251eb70f5f81eb4ebb90fd26f5 Parents: 8945fa9 f40ce9b Author: Ryan Ebanks <[email protected]> Authored: Mon Oct 20 16:10:39 2014 -0500 Committer: Ryan Ebanks <[email protected]> Committed: Mon Oct 20 16:10:39 2014 -0500 ---------------------------------------------------------------------- .../local/builders/LocalStreamBuilder.java | 109 +++-- .../streams/local/builders/StreamComponent.java | 21 +- .../local/counters/StreamsTaskCounter.java | 66 ++- .../counters/StreamsTaskCounterMXBean.java | 10 + .../streams/local/tasks/BaseStreamsTask.java | 52 ++- .../streams/local/tasks/StreamsMergeTask.java | 9 +- .../local/tasks/StreamsPersistWriterTask.java | 43 +- .../local/tasks/StreamsProcessorTask.java | 52 ++- .../local/tasks/StreamsProviderTask.java | 8 +- .../apache/streams/local/tasks/StreamsTask.java | 14 +- .../local/builders/LocalStreamBuilderTest.java | 399 ++++++++++++------- .../local/builders/ToyLocalBuilderExample.java | 5 +- .../streams/local/tasks/BasicTasksTest.java | 52 +-- .../local/tasks/StreamsProviderTaskTest.java | 7 +- .../PassthroughDatumCounterProcessor.java | 51 ++- .../test/providers/NumericMessageProvider.java | 29 +- .../local/test/writer/DatumCounterWriter.java | 61 ++- 17 files changed, 653 insertions(+), 335 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/4f2e3cf2/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/StreamComponent.java ----------------------------------------------------------------------
