Return-Path: X-Original-To: apmail-streams-commits-archive@minotaur.apache.org Delivered-To: apmail-streams-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 09AA510C38 for ; Thu, 9 Jan 2014 17:30:26 +0000 (UTC) Received: (qmail 3348 invoked by uid 500); 9 Jan 2014 17:28:38 -0000 Delivered-To: apmail-streams-commits-archive@streams.apache.org Received: (qmail 3291 invoked by uid 500); 9 Jan 2014 17:28:36 -0000 Mailing-List: contact commits-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list commits@streams.incubator.apache.org Received: (qmail 3242 invoked by uid 99); 9 Jan 2014 17:28:34 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Jan 2014 17:28:34 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Jan 2014 17:28:26 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 683BD23888A6; Thu, 9 Jan 2014 17:28:06 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1556893 [1/25] - in /incubator/streams/branches/sblackmon: ./ streams-config-graph/ streams-config-graph/src/ streams-config-graph/src/main/ streams-config-graph/src/main/java/ streams-config-graph/src/main/java/org/ streams-config-graph/s... Date: Thu, 09 Jan 2014 17:27:58 -0000 To: commits@streams.incubator.apache.org From: sblackmon@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20140109172806.683BD23888A6@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: sblackmon Date: Thu Jan 9 17:27:50 2014 New Revision: 1556893 URL: http://svn.apache.org/r1556893 Log: Adding directories containing the cool stuff Added: incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml incubator/streams/branches/sblackmon/settings.xml incubator/streams/branches/sblackmon/streams-config/ incubator/streams/branches/sblackmon/streams-config-graph/ incubator/streams/branches/sblackmon/streams-config-graph/pom.xml incubator/streams/branches/sblackmon/streams-config-graph/src/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/graph/ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/graph/PipelineGraphConfigurator.java incubator/streams/branches/sblackmon/streams-config/pom.xml incubator/streams/branches/sblackmon/streams-config/src/ incubator/streams/branches/sblackmon/streams-config/src/main/ incubator/streams/branches/sblackmon/streams-config/src/main/java/ incubator/streams/branches/sblackmon/streams-config/src/main/java/org/ incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/config/ incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java incubator/streams/branches/sblackmon/streams-config/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-config/src/main/jsonschema/StreamsConfiguration.json incubator/streams/branches/sblackmon/streams-contrib/ incubator/streams/branches/sblackmon/streams-contrib/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaConfigurator.java incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaPersistWriter.java incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaPersistWriterTask.java incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/StreamsPartitioner.java incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/jsonschema/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/jsonschema/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/jsonschema/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/jsonschema/org/apache/streams/kafka/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/jsonschema/org/apache/streams/kafka/KafkaConfiguration.json incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/resources/reference.properties incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/main/jsonschema/com/datasift/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/main/jsonschema/com/datasift/Datasift.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/main/jsonschema/com/datasift/DatasiftConfiguration.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/java/com/datasift/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/java/com/datasift/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/java/com/datasift/test/DatasiftSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-datasift/src/test/resources/datasift_jsons.txt incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/api/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/api/FacebookPostActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/feed/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/feed/FacebookPublicFeedXmlActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/jsonschema/com/facebook/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/jsonschema/com/facebook/graph/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/jsonschema/com/facebook/graph/Post.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/FacebookPostActivitySerializerTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/FacebookPostSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/org/apache/streams/data/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/org/apache/streams/data/Facebook.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/test/resources/testpost.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/streams/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/streams/gnip/facebook/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/streams/gnip/facebook/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/streams/gnip/facebook/test/FacebookEDCAsActivityTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/java/org/apache/streams/gnip/facebook/test/FacebookEDCSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-facebook/src/test/resources/FacebookEDC.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/streams/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/streams/gnip/flickr/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/streams/gnip/flickr/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/streams/gnip/flickr/test/FlickrEDCAsActivityTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/java/org/apache/streams/gnip/flickr/test/FlickrEDCSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/src/test/resources/FlickrEDC.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/main/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/main/java/com/gplus/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/main/java/com/gplus/api/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/main/java/com/gplus/api/GPlusActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/java/com/gplus/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/java/com/gplus/api/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/java/com/gplus/api/GPlusEDCAsActivityTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/src/test/resources/GPlusEDCFixed.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/main/jsonschema/com/instagram/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/main/jsonschema/com/instagram/Instagram.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/java/com/instagram/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/java/com/instagram/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/java/com/instagram/test/InstagramSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/src/test/resources/instagram_jsons.txt incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/main/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/main/java/com/reddit/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/main/java/com/reddit/api/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/main/java/com/reddit/api/RedditActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/java/com/reddit/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/java/com/reddit/api/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/java/com/reddit/api/RedditEDCAsActivityJSONTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/resources/RedditEDC.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/resources/RedditEDC.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/resources/RedditEDCFixed.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/resources/RedditEDCFlattened.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-reddit/src/test/resources/redditTest.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/java/com/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/java/com/gnip/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/java/com/gnip/test/YouTubeEDCSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/java/com/gnip/test/YoutubeEDCAsActivityTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-youtube/src/test/resources/YoutubeEDC.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/streams/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/streams/gnip/powertrack/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/streams/gnip/powertrack/ActivityXMLActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/streams/gnip/powertrack/GnipActivityFixer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/java/org/apache/streams/gnip/powertrack/PowerTrackActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/jsonschema/com/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/jsonschema/com/gnip/Gnip.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/xmlschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/xmlschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/xmlschema/com/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/xmlschema/com/gnip/binding.xjb incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/main/xmlschema/com/gnip/entry.xsd incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/apache/streams/gnip/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/apache/streams/gnip/powertrack/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/apache/streams/gnip/powertrack/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-powertrack/src/test/java/org/apache/streams/gnip/powertrack/test/PowerTrackDeserializationTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/MoreoverJsonActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/MoreoverXmlActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/MoreoverClient.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/MoreoverProvider.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/MoreoverProviderTask.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/MoreoverResult.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/MoreoverResultSetWrapper.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/util/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/util/MoreoverUtils.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/jsonschema/com/moreover/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/jsonschema/com/moreover/Moreover.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/jsonschema/com/moreover/MoreoverConfiguration.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/xmlschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/xmlschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/xmlschema/com/moreover/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/xmlschema/com/moreover/articles10.xsd incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/main/xmlschema/com/moreover/binding.xjb incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/streams/data/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/streams/data/MoreoverJsonActivitySerializerTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/streams/data/MoreoverXmlActivitySerializerTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/streams/data/util/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/java/org/apache/streams/data/util/MoreoverTestUtil.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/org/apache/streams/data/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/org/apache/streams/data/moreover.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-moreover/src/test/resources/org/apache/streams/data/moreover.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/Sysomos.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/jsonschema/com/sysomos/SysomosConfiguration.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/xmlschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/binding.xjb incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/main/xmlschema/com/sysomos/sysomos.xsd incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/java/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosJsonSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/java/com/sysomos/test/SysomosXmlSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/resources/sysomos_jsons.txt incubator/streams/branches/sblackmon/streams-contrib/streams-provider-sysomos/src/test/resources/sysomos_xmls.txt incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/README.markdown incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventClassifier.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventProcessor.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamConfigurator.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonDeleteActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonEventActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonRetweetActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/serializer/TwitterJsonTweetActivitySerializer.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/Delete.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/Retweet.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/TwitterStreamConfiguration.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/tweet.json incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/main/resources/reference.conf incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TweetSerDeTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterEventClassifierTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterStreamProviderTest.java incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/resources/ incubator/streams/branches/sblackmon/streams-contrib/streams-provider-twitter/src/test/resources/twitter_jsons.txt incubator/streams/branches/sblackmon/streams-core/ incubator/streams/branches/sblackmon/streams-core/pom.xml incubator/streams/branches/sblackmon/streams-core/src/ incubator/streams/branches/sblackmon/streams-core/src/main/ incubator/streams/branches/sblackmon/streams-core/src/main/java/ incubator/streams/branches/sblackmon/streams-core/src/main/java/org/ incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/ incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/StreamsPersistReader.java incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/StreamsPersistWriter.java incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/StreamsProcessor.java incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/StreamsProvider.java incubator/streams/branches/sblackmon/streams-core/src/main/java/org/apache/streams/core/StreamsResultSet.java incubator/streams/branches/sblackmon/streams-pojo/ incubator/streams/branches/sblackmon/streams-pojo-extensions/ incubator/streams/branches/sblackmon/streams-pojo-extensions/pom.xml incubator/streams/branches/sblackmon/streams-pojo-extensions/src/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/main/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/main/jsonschema/org/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/main/jsonschema/org/apache/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/main/jsonschema/org/apache/streams/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/main/jsonschema/org/apache/streams/ActivityExtended.json incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/org/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/org/apache/streams/pojo/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/org/apache/streams/pojo/test/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/java/org/apache/streams/pojo/test/ActivityExtendedSerDeTest.java incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/resources/ incubator/streams/branches/sblackmon/streams-pojo-extensions/src/test/resources/gnip_twitter_extended.json incubator/streams/branches/sblackmon/streams-pojo/pom.xml incubator/streams/branches/sblackmon/streams-pojo/src/ incubator/streams/branches/sblackmon/streams-pojo/src/main/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/streams/data/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/streams/data/ActivitySerializer.java incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/streams/data/util/ incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/streams/data/util/ActivityUtil.java incubator/streams/branches/sblackmon/streams-pojo/src/main/java/org/apache/streams/data/util/JsonUtil.java incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/activity.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/collection.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/media_link.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/object.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/article.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/audio.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/bookmark.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/comment.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/event.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/file.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/folder.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/group.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/list.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/note.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/person.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/photo-album.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/photo.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/place.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/playlist.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/product.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/property.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/review.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/service.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/song.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/status.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/objectTypes/video.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/ incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/favorite.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/follow.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/join.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/like.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/make-friend.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/play.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/post.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/rsvp-maybe.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/rsvp-no.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/rsvp-yes.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/save.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/share.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/tag.json incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/update.json incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/ incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/org/ incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/org/apache/ incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/org/apache/streams/ incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/org/apache/streams/pojo/ incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/org/apache/streams/pojo/xml/ incubator/streams/branches/sblackmon/streams-pojo/src/main/xmlschema/org/apache/streams/pojo/xml/activity.xsd incubator/streams/branches/sblackmon/streams-pojo/src/test/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/apache/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/apache/streams/data/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/apache/streams/data/data/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/apache/streams/data/data/util/ incubator/streams/branches/sblackmon/streams-pojo/src/test/java/org/apache/streams/data/data/util/JsonUtilTest.java incubator/streams/branches/sblackmon/streams-storm/ incubator/streams/branches/sblackmon/streams-storm/pom.xml incubator/streams/branches/sblackmon/streams-storm/src/ incubator/streams/branches/sblackmon/streams-storm/src/main/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/apache/streams/storm/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/apache/streams/storm/PipelineGraphLauncher.java incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/apache/streams/storm/trident/ incubator/streams/branches/sblackmon/streams-storm/src/main/java/org/apache/streams/storm/trident/StreamsTopology.java incubator/streams/branches/sblackmon/streams-util/ incubator/streams/branches/sblackmon/streams-util/pom.xml incubator/streams/branches/sblackmon/streams-util/src/ incubator/streams/branches/sblackmon/streams-util/src/main/ incubator/streams/branches/sblackmon/streams-util/src/main/java/ incubator/streams/branches/sblackmon/streams-util/src/main/java/org/ incubator/streams/branches/sblackmon/streams-util/src/main/java/org/apache/ incubator/streams/branches/sblackmon/streams-util/src/main/java/org/apache/streams/ incubator/streams/branches/sblackmon/streams-util/src/main/java/org/apache/streams/util/ incubator/streams/branches/sblackmon/streams-util/src/main/java/org/apache/streams/util/GuidUtils.java incubator/streams/branches/sblackmon/streams-util/src/main/java/org/apache/streams/util/RegexUtils.java Added: incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml (added) +++ incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml Thu Jan 9 17:27:50 2014 @@ -0,0 +1,24 @@ + + + + + + 67027e48-b4d0-441f-b0a2-5422c2ea11de + + \ No newline at end of file Added: incubator/streams/branches/sblackmon/settings.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/settings.xml?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/settings.xml (added) +++ incubator/streams/branches/sblackmon/settings.xml Thu Jan 9 17:27:50 2014 @@ -0,0 +1,57 @@ + + + + + + + raveldata + reader + ravelreader + + + + + raveldata + + + + true + always + + raveldata + raveldata + http://raveldata.artifactoryonline.com/raveldata/all-repos + + + + + + true + always + + raveldata + raveldata + http://raveldata.artifactoryonline.com/raveldata/all-repos + + + + + Added: incubator/streams/branches/sblackmon/streams-config-graph/pom.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-config-graph/pom.xml?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-config-graph/pom.xml (added) +++ incubator/streams/branches/sblackmon/streams-config-graph/pom.xml Thu Jan 9 17:27:50 2014 @@ -0,0 +1,72 @@ + + + + + 4.0.0 + + + org.apache.streams + streams-project + 0.1-SNAPSHOT + + + streams-config-graph + + + + gs-core + org.graphstream + 1.2 + + + com.google.guava + guava + 15.0 + + + commons-io + commons-io + + + org.slf4j + slf4j-api + + + junit + junit + + + + + src/main/java + src/test/java + + + src/main/resources + + + + + src/test/resources + + + + \ No newline at end of file Added: incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/graph/PipelineGraphConfigurator.java URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/graph/PipelineGraphConfigurator.java?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/graph/PipelineGraphConfigurator.java (added) +++ incubator/streams/branches/sblackmon/streams-config-graph/src/main/java/org/apache/streams/config/graph/PipelineGraphConfigurator.java Thu Jan 9 17:27:50 2014 @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package org.apache.streams.config.graph; + +import org.graphstream.graph.Graph; +import org.graphstream.graph.implementations.SingleGraph; +import org.graphstream.stream.file.FileSource; +import org.graphstream.stream.file.FileSourceFactory; + +import java.io.File; +import java.io.IOException; +import java.net.URISyntaxException; +import java.net.URL; +import java.util.Collections; +import java.util.Enumeration; + +/** + * Created with IntelliJ IDEA. + * User: sblackmon + * Date: 9/23/13 + * Time: 10:44 AM + * To change this template use File | Settings | File Templates. + */ +public class PipelineGraphConfigurator { + + public static Graph pipeline = loadPipeline(); + + private static Graph loadPipeline() { + + Graph pipeline = new SingleGraph("pipelines"); + + // this class looks for any pipelines specified with a graph definition + // each is loaded into the execution graph + // the application is responsible for launching each + Enumeration pipelineFiles; + try { + pipelineFiles = PipelineGraphConfigurator.class.getClassLoader().getResources("*.dot"); + + for( URL pipelineFile : Collections.list(pipelineFiles) ) { + File file = new File(pipelineFile.toURI()); + String filePath = file.getAbsolutePath(); + FileSource fileSource = FileSourceFactory.sourceFor(filePath); + + fileSource.addSink(pipeline); + + try { + fileSource.begin(filePath); + + while (fileSource.nextEvents()) { + // Optionally some code here ... + } + } catch( IOException e) { + e.printStackTrace(); + } + + try { + fileSource.end(); + } catch( IOException e) { + e.printStackTrace(); + } finally { + fileSource.removeSink(pipeline); + } + } + } catch (IOException e) { + e.printStackTrace(); + } catch (URISyntaxException e) { + e.printStackTrace(); + } + + return pipeline; + } +} Added: incubator/streams/branches/sblackmon/streams-config/pom.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-config/pom.xml?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-config/pom.xml (added) +++ incubator/streams/branches/sblackmon/streams-config/pom.xml Thu Jan 9 17:27:50 2014 @@ -0,0 +1,142 @@ + + + + + 4.0.0 + + + org.apache.streams + streams-project + 0.1-SNAPSHOT + + + streams-config + + + + com.typesafe + config + 1.0.2 + + + + + + + + com.google.guava + guava + 15.0 + + + com.google.collections + google-collections + 1.0 + + + com.fasterxml.jackson.core + jackson-core + + + com.fasterxml.jackson.core + jackson-annotations + + + org.jsonschema2pojo + jsonschema2pojo-core + + + com.fasterxml.jackson.dataformat + jackson-dataformat-yaml + + + commons-io + commons-io + + + org.slf4j + slf4j-api + + + junit + junit + + + + + src/main/java + src/test/java + + + src/main/resources + + + + + src/test/resources + + + + + org.codehaus.mojo + build-helper-maven-plugin + 1.8 + + + add-source + generate-sources + + add-source + + + + target/generated-sources/jsonschema2pojo + + + + + + + org.jsonschema2pojo + jsonschema2pojo-maven-plugin + + + true + true + + src/main/jsonschema + + target/generated-sources/jsonschema2pojo + org.apache.streams + true + false + + + + + generate + + + + + + + \ No newline at end of file Added: incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java (added) +++ incubator/streams/branches/sblackmon/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java Thu Jan 9 17:27:50 2014 @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package org.apache.streams.config; + +import com.typesafe.config.Config; +import com.typesafe.config.ConfigFactory; + +/** + * Created with IntelliJ IDEA. + * User: sblackmon + * Date: 9/23/13 + * Time: 10:44 AM + * To change this template use File | Settings | File Templates. + */ +public class StreamsConfigurator { + + /* + Pull all configuration files from the classpath, system properties, and environment variables + */ + public static Config config = ConfigFactory.load(); + +} Added: incubator/streams/branches/sblackmon/streams-config/src/main/jsonschema/StreamsConfiguration.json URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-config/src/main/jsonschema/StreamsConfiguration.json?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-config/src/main/jsonschema/StreamsConfiguration.json (added) +++ incubator/streams/branches/sblackmon/streams-config/src/main/jsonschema/StreamsConfiguration.json Thu Jan 9 17:27:50 2014 @@ -0,0 +1,12 @@ +{ + "type": "object", + "$schema": "http://json-schema.org/draft-03/schema", + "id": "#", + "javaType" : "org.apache.streams.StreamsConfiguration", + "javaInterfaces": ["java.io.Serializable"], + "properties": { + "pipeline": { + "type" : "string" + } + } +} \ No newline at end of file Added: incubator/streams/branches/sblackmon/streams-contrib/pom.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-contrib/pom.xml?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-contrib/pom.xml (added) +++ incubator/streams/branches/sblackmon/streams-contrib/pom.xml Thu Jan 9 17:27:50 2014 @@ -0,0 +1,69 @@ + + + + + + streams-project + org.apache.streams + 0.1-SNAPSHOT + + 4.0.0 + + streams-contrib + + pom + + + + + + + + streams-persist-kafka + streams-provider-datasift + streams-provider-facebook + streams-provider-gnip + streams-provider-moreover + streams-provider-twitter + streams-provider-sysomos + + + + + + + org.apache.streams + streams-config + ${project.version} + + + org.apache.streams + streams-core + ${project.version} + + + org.apache.streams + streams-pojo + ${project.version} + + + + Added: incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java (added) +++ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java Thu Jan 9 17:27:50 2014 @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package org.apache.streams.console; + +import org.apache.streams.core.StreamsDatum; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.util.Random; +import java.util.concurrent.BlockingQueue; + +public class ConsolePersistWriterTask implements Runnable { + + private static final Logger LOGGER = LoggerFactory.getLogger(ConsolePersistWriterTask.class); + + private ConsolePersistWriter writer; + + public ConsolePersistWriterTask(ConsolePersistWriter writer, + BlockingQueue outqueue) { + this.writer = writer; + } + + @Override + public void run() { + while(true) { + try { + StreamsDatum entry = writer.persistQueue.remove(); + writer.write(entry); + Thread.sleep(new Random().nextInt(100)); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + +} Added: incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/pom.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/pom.xml?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/pom.xml (added) +++ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/pom.xml Thu Jan 9 17:27:50 2014 @@ -0,0 +1,130 @@ + + + + streams-contrib + org.apache.streams + 0.1-SNAPSHOT + + 4.0.0 + + streams-persist-kafka + + + + org.apache.streams + streams-config + 0.1-SNAPSHOT + + + org.apache.streams + streams-core + 0.1-SNAPSHOT + + + org.apache.streams + streams-pojo + 0.1-SNAPSHOT + + + org.apache.streams + streams-util + 0.1-SNAPSHOT + + + org.apache.kafka + kafka_2.9.2 + 0.8.0 + + + log4j + log4j + + + org.slf4j + slf4j-log4j12 + + + + + org.clojure + clojure + + + com.101tec + zkclient + 0.3 + compile + + + log4j + log4j + + + org.slf4j + slf4j-log4j12 + + + + + org.apache.zookeeper + zookeeper + + + log4j + log4j + + + org.slf4j + slf4j-log4j12 + + + + + + + + org.codehaus.mojo + build-helper-maven-plugin + 1.8 + + + add-source + generate-sources + + add-source + + + + target/generated-sources/jsonschema2pojo + + + + + + + org.jsonschema2pojo + jsonschema2pojo-maven-plugin + + true + true + + src/main/jsonschema/org/apache/streams/kafka + + target/generated-sources/jsonschema2pojo + org.apache.streams.kafka.pojo + true + false + + + + + generate + + + + + + + \ No newline at end of file Added: incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaConfigurator.java URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaConfigurator.java?rev=1556893&view=auto ============================================================================== --- incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaConfigurator.java (added) +++ incubator/streams/branches/sblackmon/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/KafkaConfigurator.java Thu Jan 9 17:27:50 2014 @@ -0,0 +1,27 @@ +package org.apache.streams.kafka; + +import com.typesafe.config.Config; +import org.apache.streams.config.StreamsConfigurator; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Created by sblackmon on 12/10/13. + */ +public class KafkaConfigurator { + + private final static Logger LOGGER = LoggerFactory.getLogger(KafkaConfigurator.class); + + public static KafkaConfiguration detectConfiguration(Config kafka) { + String brokerlist = StreamsConfigurator.config.getString("kafka.metadata.broker.list"); + String topic = StreamsConfigurator.config.getString("kafka.topic"); + + KafkaConfiguration kafkaConfiguration = new KafkaConfiguration(); + + kafkaConfiguration.setBrokerlist(brokerlist); + kafkaConfiguration.setBrokerlist(brokerlist); + + return kafkaConfiguration; + } + +}