Merge commit '01716fe31d6e7507b5a1aaec7e7060de0371c68b' into STREAMS-49
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/3026b831 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/3026b831 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/3026b831 Branch: refs/heads/STREAMS-49 Commit: 3026b83190a8564ba55b23e1130ac7e986a23488 Parents: 073b083 01716fe Author: sblackmon <[email protected]> Authored: Fri Nov 7 12:05:07 2014 -0800 Committer: sblackmon <[email protected]> Committed: Fri Nov 7 12:05:07 2014 -0800 ---------------------------------------------------------------------- pom.xml | 2 + streams-components/pom.xml | 62 +++++ streams-components/streams-http/README.md | 16 ++ streams-components/streams-http/pom.xml | 153 +++++++++++ .../components/http/HttpConfigurator.java | 62 +++++ .../http/processor/SimpleHTTPGetProcessor.java | 268 +++++++++++++++++++ .../http/provider/SimpleHTTPGetProvider.java | 230 ++++++++++++++++ .../components/http/HttpConfiguration.json | 50 ++++ .../http/HttpProcessorConfiguration.json | 28 ++ .../http/HttpProviderConfiguration.json | 18 ++ streams-contrib/pom.xml | 5 +- .../streams-processor-peoplepattern/pom.xml | 138 ++++++++++ .../peoplepattern/AccountTypeProcessor.java | 75 ++++++ .../peoplepattern/DemographicsProcessor.java | 76 ++++++ .../streams/peoplepattern/AccountType.json | 27 ++ .../streams/peoplepattern/Demographics.json | 60 +++++ .../resources/templates/peoplepatternactor.json | 25 ++ .../api/FacebookPostActivitySerializer.java | 1 - .../processor/GooglePlusCommentProcessor.java | 87 ++++++ .../util/GPlusCommentDeserializer.java | 98 +++++++ .../serializer/util/GooglePlusActivityUtil.java | 50 ++++ .../gplus/GooglePlusCommentSerDeTest.java | 114 ++++++++ .../resources/google_plus_comments_jsons.txt | 3 + .../streams-provider-twitter/pom.xml | 5 + .../processor/TwitterUrlApiProcessor.java | 73 +++++ .../provider/TwitterTimelineProvider.java | 7 +- streams-pojo-extensions/pom.xml | 64 +++++ .../apache/streams/data/util/ExtensionUtil.java | 108 ++++++++ .../apache/streams/data/util/ActivityUtil.java | 14 +- .../jackson/StreamsDateTimeDeserializer.java | 23 +- .../streams/jackson/StreamsJacksonMapper.java | 20 ++ .../streams/jackson/StreamsJacksonModule.java | 9 + .../org/apache/streams/pojo/json/activity.json | 3 +- .../org/apache/streams/pojo/json/object.json | 2 +- .../local/builders/LocalStreamBuilder.java | 5 + .../streams/local/tasks/StreamsMergeTask.java | 7 + .../local/tasks/StreamsPersistWriterTask.java | 18 +- .../local/tasks/StreamsProcessorTask.java | 20 +- .../local/tasks/StreamsProviderTask.java | 15 ++ .../apache/streams/local/tasks/StreamsTask.java | 4 + .../local/builders/LocalStreamBuilderTest.java | 32 ++- .../streams/local/tasks/BasicTasksTest.java | 26 +- 42 files changed, 2072 insertions(+), 31 deletions(-) ----------------------------------------------------------------------
