Merge commit '94c3fd5ea577f0710f61e7eb4c5c9af57ec33001'
* commit '94c3fd5ea577f0710f61e7eb4c5c9af57ec33001':
improvements and new test for STREAMS-325
fix one reference to removed config field adapts dropwizard runtime configuration
completed, all tests passing resolves #226 resolves #294 resolves #325
initial refactoring
resolves STREAMS-325 #325
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/39c07f1d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/39c07f1d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/39c07f1d
Branch: refs/heads/master
Commit: 39c07f1d64757626acf496028a0367fa5d347ff0
Parents: e7bf641 94c3fd5
Author: Steve Blackmon (@steveblackmon) <sblackmon@apache.org>
Authored: Fri Jun 19 16:44:46 2015 -0500
Committer: Steve Blackmon (@steveblackmon) <sblackmon@apache.org>
Committed: Fri Jun 19 16:44:46 2015 -0500
----------------------------------------------------------------------
.../main/jsonschema/StreamsConfiguration.json | 38 ++++--
streams-monitoring/pom.xml | 11 +-
.../tasks/BroadcastMonitorThread.java | 124 +++++++++----------
.../monitoring/MonitoringConfiguration.json | 23 ++++
.../tasks/BroadcastMonitorThreadTest.java | 38 +++++-
.../dropwizard/StreamDropwizardBuilder.java | 8 ++
.../streams/dropwizard/StreamsApplication.java | 6 +-
.../local/builders/LocalStreamBuilder.java | 75 +++++++----
.../streams/local/builders/StreamComponent.java | 13 +-
.../streams/local/tasks/BaseStreamsTask.java | 41 ++----
.../streams/local/tasks/StreamsMergeTask.java | 11 +-
.../local/tasks/StreamsPersistWriterTask.java | 22 ++--
.../local/tasks/StreamsProcessorTask.java | 22 ++--
.../local/tasks/StreamsProviderTask.java | 24 ++--
.../apache/streams/local/tasks/StreamsTask.java | 13 +-
.../jsonschema/LocalRuntimeConfiguration.json | 8 +-
.../streams/local/tasks/BasicTasksTest.java | 60 +++------
17 files changed, 286 insertions(+), 251 deletions(-)
----------------------------------------------------------------------
|