streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sblack...@apache.org
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 GMT
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 @@
+<!--
+  ~ 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.
+  -->
+
+<atlassian-ide-plugin>
+  <project-configuration id="1">
+    <servers id="2" />
+    <default-jira-server id="3">67027e48-b4d0-441f-b0a2-5422c2ea11de</default-jira-server>
+  </project-configuration>
+</atlassian-ide-plugin>
\ 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 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ 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.
+  -->
+
+<settings
+	xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd"
+	xmlns="http://maven.apache.org/SETTINGS/1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+	<servers>
+		<server>
+            <id>raveldata</id>
+            <username>reader</username>
+			<password>ravelreader</password>
+		</server>
+	</servers>
+	<profiles>
+		<profile>
+			<id>raveldata</id>
+			<repositories>
+				<repository>
+					<snapshots>
+						<enabled>true</enabled>
+						<updatePolicy>always</updatePolicy>
+					</snapshots>
+					<id>raveldata</id>
+					<name>raveldata</name>
+					<url>http://raveldata.artifactoryonline.com/raveldata/all-repos</url>
+				</repository>
+			</repositories>
+			<pluginRepositories>
+				<pluginRepository>
+					<snapshots>
+						<enabled>true</enabled>
+						<updatePolicy>always</updatePolicy>
+					</snapshots>
+					<id>raveldata</id>
+					<name>raveldata</name>
+					<url>http://raveldata.artifactoryonline.com/raveldata/all-repos</url>
+				</pluginRepository>
+			</pluginRepositories>
+		</profile>
+	</profiles>
+</settings>

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 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ 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.
+  -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.apache.streams</groupId>
+        <artifactId>streams-project</artifactId>
+        <version>0.1-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>streams-config-graph</artifactId>
+
+    <dependencies>
+        <dependency>
+            <artifactId>gs-core</artifactId>
+            <groupId>org.graphstream</groupId>
+            <version>1.2</version>
+        </dependency>
+        <dependency>
+        <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>15.0</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <sourceDirectory>src/main/java</sourceDirectory>
+        <testSourceDirectory>src/test/java</testSourceDirectory>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+            </resource>
+        </resources>
+        <testResources>
+            <testResource>
+                <directory>src/test/resources</directory>
+            </testResource>
+        </testResources>
+    </build>
+</project>
\ 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<URL> 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 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ 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.
+  -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.apache.streams</groupId>
+        <artifactId>streams-project</artifactId>
+        <version>0.1-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>streams-config</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.typesafe</groupId>
+            <artifactId>config</artifactId>
+            <version>1.0.2</version>
+        </dependency>
+        <!--<dependency>-->
+            <!--<groupId>commons-configuration</groupId>-->
+            <!--<artifactId>commons-configuration</artifactId>-->
+            <!--<version>1.10</version>-->
+        <!--</dependency>-->
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>15.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.collections</groupId>
+            <artifactId>google-collections</artifactId>
+            <version>1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-annotations</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.jsonschema2pojo</groupId>
+            <artifactId>jsonschema2pojo-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-yaml</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <sourceDirectory>src/main/java</sourceDirectory>
+        <testSourceDirectory>src/test/java</testSourceDirectory>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+            </resource>
+        </resources>
+        <testResources>
+            <testResource>
+                <directory>src/test/resources</directory>
+            </testResource>
+        </testResources>
+        <plugins>
+            <plugin>
+                <groupId>org.codehaus.mojo</groupId>
+                <artifactId>build-helper-maven-plugin</artifactId>
+                <version>1.8</version>
+                <executions>
+                    <execution>
+                        <id>add-source</id>
+                        <phase>generate-sources</phase>
+                        <goals>
+                            <goal>add-source</goal>
+                        </goals>
+                        <configuration>
+                            <sources>
+                                <source>target/generated-sources/jsonschema2pojo</source>
+                            </sources>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.jsonschema2pojo</groupId>
+                <artifactId>jsonschema2pojo-maven-plugin</artifactId>
+
+                <configuration>
+                    <addCompileSourceRoot>true</addCompileSourceRoot>
+                    <generateBuilders>true</generateBuilders>
+                    <sourcePaths>
+                        <sourcePath>src/main/jsonschema</sourcePath>
+                    </sourcePaths>
+                    <outputDirectory>target/generated-sources/jsonschema2pojo</outputDirectory>
+                    <targetPackage>org.apache.streams</targetPackage>
+                    <useLongIntegers>true</useLongIntegers>
+                    <useJodaDates>false</useJodaDates>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>generate</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>
\ 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 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ 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.
+  -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>streams-project</artifactId>
+        <groupId>org.apache.streams</groupId>
+        <version>0.1-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>streams-contrib</artifactId>
+
+    <packaging>pom</packaging>
+
+    <properties>
+
+    </properties>
+
+    <modules>
+        <!--<module>streams-persist-console</module>-->
+        <module>streams-persist-kafka</module>
+        <module>streams-provider-datasift</module>
+        <module>streams-provider-facebook</module>
+        <module>streams-provider-gnip</module>
+        <module>streams-provider-moreover</module>
+        <module>streams-provider-twitter</module>
+        <module>streams-provider-sysomos</module>
+        <!--<module>streams-proxy-semantria</module>-->
+    </modules>
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>org.apache.streams</groupId>
+                <artifactId>streams-config</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.streams</groupId>
+                <artifactId>streams-core</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.streams</groupId>
+                <artifactId>streams-pojo</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+</project>

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<Object> 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 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>streams-contrib</artifactId>
+        <groupId>org.apache.streams</groupId>
+        <version>0.1-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>streams-persist-kafka</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.streams</groupId>
+            <artifactId>streams-config</artifactId>
+            <version>0.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.streams</groupId>
+            <artifactId>streams-core</artifactId>
+            <version>0.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.streams</groupId>
+            <artifactId>streams-pojo</artifactId>
+            <version>0.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.streams</groupId>
+            <artifactId>streams-util</artifactId>
+            <version>0.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka_2.9.2</artifactId>
+            <version>0.8.0</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>log4j</groupId>
+                    <artifactId>log4j</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency> <!-- Have to add to be able to .get() from storm tuple -->
+            <groupId>org.clojure</groupId>
+            <artifactId>clojure</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.101tec</groupId>
+            <artifactId>zkclient</artifactId>
+            <version>0.3</version>
+            <scope>compile</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>log4j</groupId>
+                    <artifactId>log4j</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.zookeeper</groupId>
+            <artifactId>zookeeper</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>log4j</groupId>
+                    <artifactId>log4j</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.codehaus.mojo</groupId>
+                <artifactId>build-helper-maven-plugin</artifactId>
+                <version>1.8</version>
+                <executions>
+                    <execution>
+                        <id>add-source</id>
+                        <phase>generate-sources</phase>
+                        <goals>
+                            <goal>add-source</goal>
+                        </goals>
+                        <configuration>
+                            <sources>
+                                <source>target/generated-sources/jsonschema2pojo</source>
+                            </sources>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.jsonschema2pojo</groupId>
+                <artifactId>jsonschema2pojo-maven-plugin</artifactId>
+                <configuration>
+                    <addCompileSourceRoot>true</addCompileSourceRoot>
+                    <generateBuilders>true</generateBuilders>
+                    <sourcePaths>
+                        <sourcePath>src/main/jsonschema/org/apache/streams/kafka</sourcePath>
+                    </sourcePaths>
+                    <outputDirectory>target/generated-sources/jsonschema2pojo</outputDirectory>
+                    <targetPackage>org.apache.streams.kafka.pojo</targetPackage>
+                    <useLongIntegers>true</useLongIntegers>
+                    <useJodaDates>false</useJodaDates>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>generate</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>
\ 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;
+    }
+
+}



Mime
View raw message