streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reba...@apache.org
Subject [1/3] incubator-streams git commit: Merge remote-tracking branch 'robdouglas/STREAMS-216'
Date Wed, 19 Nov 2014 20:50:12 GMT
Repository: incubator-streams
Updated Branches:
  refs/heads/master 590b053b9 -> 1b5574142


Merge remote-tracking branch 'robdouglas/STREAMS-216'


Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/31ba80fc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/31ba80fc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/31ba80fc

Branch: refs/heads/master
Commit: 31ba80fcbe9d6728da3d7a6d67a5a1ef661e626d
Parents: 91dd9a3 a20f01a
Author: Ryan Ebanks <ryanebanks@gmail.com>
Authored: Wed Nov 19 13:40:08 2014 -0600
Committer: Ryan Ebanks <ryanebanks@gmail.com>
Committed: Wed Nov 19 13:40:08 2014 -0600

----------------------------------------------------------------------
 .../tasks/BroadcastMonitorThread.java           |  5 +-
 .../org/apache/streams/pojo/json/Broadcast.json |  8 +++
 .../local/builders/LocalStreamBuilder.java      | 37 +++++++++++---
 .../streams/local/builders/StreamComponent.java | 31 +++++++-----
 .../local/counters/DatumStatusCounter.java      |  9 +++-
 .../local/counters/StreamsTaskCounter.java      | 16 ++++--
 .../streams/local/queues/ThroughputQueue.java   | 52 +++++++++++++++++---
 .../streams/local/tasks/BaseStreamsTask.java    | 41 ++++++++++++++-
 .../streams/local/tasks/StreamsMergeTask.java   |  7 ++-
 .../local/tasks/StreamsPersistWriterTask.java   | 11 +++--
 .../local/tasks/StreamsProcessorTask.java       | 14 ++++--
 .../local/tasks/StreamsProviderTask.java        | 11 +++--
 .../local/builders/LocalStreamBuilderTest.java  |  9 ++--
 .../local/counters/DatumStatusCounterTest.java  | 22 ++++-----
 .../local/counters/StreamsTaskCounterTest.java  | 16 +++---
 .../queues/ThroughputQueueSingleThreadTest.java | 15 +++---
 .../streams/local/tasks/BasicTasksTest.java     |  6 +--
 .../local/tasks/StreamsProviderTaskTest.java    | 10 ++--
 18 files changed, 238 insertions(+), 82 deletions(-)
----------------------------------------------------------------------



Mime
View raw message