You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by re...@apache.org on 2014/10/20 19:29:01 UTC
[09/11] git commit: STREAMS-191 | Merged apache master
STREAMS-191 | Merged apache master
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/ae016213
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/ae016213
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/ae016213
Branch: refs/heads/master
Commit: ae0162135b6cf9ef277a6cf1d0b4b3f60df4cfcf
Parents: fd3ffe8 4704012
Author: Ryan Ebanks <ry...@gmail.com>
Authored: Mon Oct 13 11:01:39 2014 -0500
Committer: Ryan Ebanks <ry...@gmail.com>
Committed: Mon Oct 13 11:01:39 2014 -0500
----------------------------------------------------------------------
pom.xml | 9 +-
streams-config/pom.xml | 1 -
.../streams-persist-s3/pom.xml | 1 -
streams-contrib/streams-persist-hdfs/pom.xml | 13 +-
.../apache/streams/hdfs/HdfsConfigurator.java | 38 +-
.../streams/hdfs/WebHdfsPersistReader.java | 13 +-
.../streams/hdfs/WebHdfsPersistReaderTask.java | 5 +-
.../streams/hdfs/WebHdfsPersistWriter.java | 14 +-
.../apache/streams/hdfs/HdfsConfiguration.json | 6 +
.../streams/hdfs/HdfsWriterConfiguration.json | 5 +
.../hdfs/test/HdfsPersistConfigTest.java | 169 +++
streams-contrib/streams-persist-kafka/pom.xml | 1 -
streams-contrib/streams-persist-mongo/pom.xml | 1 -
.../streams-provider-datasift/pom.xml | 2 -
.../streams-provider-facebook/pom.xml | 1 -
.../gnip-edc-facebook/pom.xml | 1 -
.../gnip-edc-youtube/pom.xml | 3 +-
.../gnip-powertrack/pom.xml | 39 +-
.../google-gmail/pom.xml | 1 -
.../google-gplus/pom.xml | 1 -
.../streams-provider-instagram/pom.xml | 1 -
.../streams-provider-moreover/pom.xml | 3 +-
streams-contrib/streams-provider-rss/pom.xml | 50 +-
.../streams/rss/provider/RssStreamProvider.java | 169 ++-
.../rss/provider/RssStreamProviderTask.java | 214 +++-
.../provider/perpetual/RssFeedScheduler.java | 112 ++
.../rss/provider/RssStreamProviderTaskTest.java | 148 +++
.../rss/provider/RssStreamProviderTest.java | 103 ++
.../perpetual/RssFeedSchedulerTest.java | 101 ++
.../test/resources/test_rss_xml/economist1.xml | 233 ++++
.../test/resources/test_rss_xml/economist2.xml | 1069 ++++++++++++++++++
.../test_rss_xml/economistCombined.xml | 221 ++++
.../streams-provider-sysomos/pom.xml | 1 -
.../streams-provider-twitter/pom.xml | 1 -
.../provider/TwitterTimelineProvider.java | 10 +-
.../provider/TwitterTimelineProviderTask.java | 6 +-
streams-pojo/pom.xml | 1 -
.../streams/local/queues/ThroughputQueue.java | 289 +++--
.../local/queues/ThroughputQueueMXBean.java | 22 +-
.../queues/ThroughputQueueMulitThreadTest.java | 17 +
.../queues/ThroughputQueueSingleThreadTest.java | 90 +-
41 files changed, 2834 insertions(+), 351 deletions(-)
----------------------------------------------------------------------