Merge pull request #8 from apache/master Merge Apache Master 2014/10/20
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/6ecf46d2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/6ecf46d2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/6ecf46d2 Branch: refs/heads/master Commit: 6ecf46d2d371ff1ee27d6f3da189388892148fcb Parents: 2a635df 7b01eb4 Author: Ryan Ebanks <[email protected]> Authored: Mon Oct 20 12:50:25 2014 -0500 Committer: Ryan Ebanks <[email protected]> Committed: Mon Oct 20 12:50:25 2014 -0500 ---------------------------------------------------------------------- .../local/builders/LocalStreamBuilder.java | 58 +-- .../streams/local/builders/StreamComponent.java | 21 +- .../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 ++- 15 files changed, 569 insertions(+), 292 deletions(-) ----------------------------------------------------------------------
