You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/01/09 18:27:58 UTC
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...
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;
+ }
+
+}