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/11/23 21:12:06 UTC
[21/28] incubator-streams git commit: Merge branch 'STREAMS-68,
218' into steveblackmon-master
Merge branch 'STREAMS-68,218' into steveblackmon-master
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/a6761f07
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/a6761f07
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/a6761f07
Branch: refs/heads/master
Commit: a6761f07f5192837f6f9aaaaedf01954fdf2a1b2
Parents: b9010bc b5cb7eb
Author: Steve Blackmon <sb...@w2odigital.com>
Authored: Sun Nov 23 13:06:24 2014 -0600
Committer: Steve Blackmon <sb...@w2odigital.com>
Committed: Sun Nov 23 13:06:24 2014 -0600
----------------------------------------------------------------------
.gitignore | 6 +
streams-components/pom.xml | 1 +
streams-components/streams-converters/pom.xml | 140 ++++++++++
.../converter/ActivityConverterProcessor.java | 167 ++++++++++++
.../BaseActivityConverterResolver.java | 31 +++
.../converter/BaseDocumentClassifier.java | 66 +++++
.../BaseObjectNodeActivityConverter.java | 65 +++++
.../converter/BaseStringActivityConverter.java | 65 +++++
.../CleanAdditionalPropertiesProcessor.java | 62 +++++
.../converter/TypeConverterProcessor.java | 83 ++++++
.../streams/converter/TypeConverterUtil.java | 51 ++++
...ActivityConverterProcessorConfiguration.json | 23 ++
.../test/ActivityConverterProcessorTest.java | 86 ++++++
.../test/TypeConverterProcessorTest.java | 94 +++++++
streams-contrib/pom.xml | 1 -
.../streams-processor-jackson/pom.xml | 86 ------
.../CleanAdditionalPropertiesProcessor.java | 62 -----
.../streams/jackson/TypeConverterProcessor.java | 112 --------
.../test/TypeConverterProcessorTest.java | 95 -------
.../streams-provider-datasift/pom.xml | 2 +-
.../DatasiftActivitySerializerProcessor.java | 9 +-
.../DatasiftTypeConverterProcessor.java | 8 +-
.../serializer/DatasiftActivityConverter.java | 77 ++++++
.../serializer/DatasiftActivitySerializer.java | 65 -----
.../serializer/DatasiftConverterResolver.java | 50 ++++
.../serializer/DatasiftEventClassifier.java | 35 +--
.../DatasiftInstagramActivityConverter.java | 124 +++++++++
.../DatasiftInstagramActivitySerializer.java | 124 ---------
.../DatasiftInteractionActivityConverter.java | 222 +++++++++++++++
.../DatasiftInteractionActivitySerializer.java | 222 ---------------
.../DatasiftTwitterActivityConverter.java | 272 +++++++++++++++++++
.../DatasiftTwitterActivitySerializer.java | 272 -------------------
.../datasift/util/StreamsDatasiftMapper.java | 3 +-
.../com/datasift/test/DatasiftSerDeTest.java | 2 +-
.../DatasiftActivityConverterTest.java | 85 ++++++
.../DatasiftActivitySerializerTest.java | 86 ------
.../serializer/DatasiftEventClassifierTest.java | 26 +-
.../DatasiftInstagramActivityConverterTest.java | 35 +++
...DatasiftInstagramActivitySerializerTest.java | 43 ---
...atasiftInteractionActivityConverterTest.java | 40 +++
...tasiftInteractionActivitySerializerTest.java | 48 ----
.../DatasiftTwitterActivityConverterTest.java | 35 +++
.../DatasiftTwitterActivitySerializerTest.java | 43 ---
.../api/FacebookPageActivityConverter.java | 76 ++++++
.../api/FacebookPageActivitySerializer.java | 66 -----
.../api/FacebookPostActivityConverter.java | 79 ++++++
.../api/FacebookPostActivitySerializer.java | 69 -----
.../processor/FacebookTypeConverter.java | 22 +-
.../provider/FacebookEventClassifier.java | 57 ----
.../serializer/FacebookConverterResolver.java | 62 +++++
.../serializer/FacebookDocumentClassifier.java | 75 +++++
.../FacebookStreamsPostConverter.java | 60 ++++
.../FacebookStreamsPostSerializer.java | 60 ----
.../test/FacebookActivityActorSerDeTest.java | 6 +-
.../test/FacebookActivitySerDeTest.java | 4 +-
.../test/FacebookDocumentClassifierTest.java | 57 ++++
.../test/FacebookEventClassifierTest.java | 57 ----
.../streams/facebook/test/SimplePageTest.java | 4 +-
.../com/gplus/api/GPlusActivityConverter.java | 93 +++++++
.../com/gplus/api/GPlusActivitySerializer.java | 93 -------
.../com/gplus/api/GPlusEDCAsActivityTest.java | 4 +-
.../com/reddit/api/RedditActivityConverter.java | 107 ++++++++
.../reddit/api/RedditActivitySerializer.java | 107 --------
.../reddit/api/RedditEDCAsActivityJSONTest.java | 4 +-
.../ActivityXMLActivityConverter.java | 240 ++++++++++++++++
.../ActivityXMLActivitySerializer.java | 240 ----------------
.../powertrack/PowerTrackActivityConverter.java | 121 +++++++++
.../PowerTrackActivitySerializer.java | 121 ---------
.../test/PowerTrackDeserializationTest.java | 6 +-
.../gmail/provider/GMailImapProviderTask.java | 5 +-
.../provider/GMailMessageActivityConverter.java | 202 ++++++++++++++
.../GMailMessageActivitySerializer.java | 212 ---------------
.../processor/GooglePlusCommentProcessor.java | 3 +
.../processor/GooglePlusTypeConverter.java | 4 +
.../gplus/provider/GPlusActivityConverter.java | 67 +++++
.../gplus/provider/GPlusActivitySerializer.java | 67 -----
.../gplus/provider/GPlusEventProcessor.java | 94 -------
.../processor/InstagramTypeConverter.java | 10 +-
.../InstagramJsonActivityConverter.java | 78 ++++++
.../InstagramJsonActivitySerializer.java | 78 ------
.../serializer/InstagramUserInfoConverter.java | 81 ++++++
.../serializer/InstagramUserInfoSerializer.java | 83 ------
.../data/MoreoverJsonActivitySerializer.java | 93 -------
.../data/MoreoverXmlActivitySerializer.java | 105 -------
.../conversion/MoreoverConverterResolver.java | 20 ++
.../conversion/MoreoverDocumentClassifier.java | 22 ++
.../MoreoverJsonActivityConverter.java | 94 +++++++
.../MoreoverXmlActivityConverter.java | 106 ++++++++
.../data/MoreoverJsonActivityConverterTest.java | 66 +++++
.../MoreoverJsonActivitySerializerTest.java | 72 -----
.../data/MoreoverXmlActivityConverterTest.java | 62 +++++
.../data/MoreoverXmlActivitySerializerTest.java | 61 -----
.../streams/rss/processor/RssTypeConverter.java | 10 +-
.../rss/provider/RssDocumentClassifier.java | 35 +++
.../rss/provider/RssEventClassifier.java | 32 ---
.../streams/rss/provider/RssEventProcessor.java | 103 -------
.../rss/serializer/RssConverterResolver.java | 18 ++
.../serializer/SyndEntryActivityConverter.java | 232 ++++++++++++++++
.../serializer/SyndEntryActivitySerializer.java | 235 ----------------
.../test/SyndEntryActivitySerizlizerTest.java | 4 +-
.../SysomosBeatActivityConverter.java | 35 ++-
.../conversion/SysomosConverterResolver.java | 18 ++
.../conversion/SysomosDocumentClassifier.java | 16 ++
.../sysomos/processor/SysomosTypeConverter.java | 4 +
.../streams-provider-twitter/pom.xml | 9 +-
.../FetchAndReplaceTwitterProcessor.java | 4 +-
.../processor/TwitterProfileProcessor.java | 4 +-
.../provider/TwitterEventClassifier.java | 99 -------
.../TwitterUserInformationProvider.java | 2 +-
.../serializer/StreamsTwitterMapper.java | 10 +-
.../serializer/TwitterConverterResolver.java | 61 +++++
.../serializer/TwitterDocumentClassifier.java | 85 ++++++
.../TwitterJsonActivityConverter.java | 81 ++++++
.../TwitterJsonActivitySerializer.java | 70 -----
.../TwitterJsonDeleteActivityConverter.java | 84 ++++++
.../TwitterJsonDeleteActivitySerializer.java | 94 -------
.../TwitterJsonRetweetActivityConverter.java | 78 ++++++
.../TwitterJsonRetweetActivitySerializer.java | 79 ------
.../TwitterJsonTweetActivityConverter.java | 76 ++++++
.../TwitterJsonTweetActivitySerializer.java | 77 ------
.../TwitterJsonUserActivityConverter.java | 77 ++++++
.../TwitterJsonUserActivitySerializer.java | 78 ------
...terJsonUserstreameventActivityConverter.java | 115 ++++++++
...erJsonUserstreameventActivitySerializer.java | 115 --------
.../streams/twitter/test/FullTweetTest.java | 119 ++++++++
.../streams/twitter/test/SimpleTweetTest.java | 43 ++-
.../twitter/test/TweetActivitySerDeTest.java | 32 ++-
.../streams/twitter/test/TweetSerDeTest.java | 8 +-
.../test/TwitterDocumentClassifierTest.java | 117 ++++++++
.../test/TwitterEventClassifierTest.java | 100 -------
.../apache/streams/data/ActivityConverter.java | 60 ++++
.../streams/data/ActivityConverterFactory.java | 27 ++
.../streams/data/ActivityConverterResolver.java | 43 +++
.../apache/streams/data/ActivitySerializer.java | 60 ----
.../apache/streams/data/DocumentClassifier.java | 41 +++
.../apache/streams/data/util/ActivityUtil.java | 3 +
.../ActivityDeserializerException.java | 7 +-
.../exceptions/ActivitySerializerException.java | 7 +-
.../jackson/StreamsDateTimeDeserializer.java | 10 +-
.../jackson/StreamsDateTimeSerializer.java | 5 +-
.../streams/jackson/StreamsJacksonMapper.java | 18 +-
.../streams/jackson/StreamsJacksonModule.java | 3 +-
.../streams/pig/StreamsComponentFactory.java | 13 +-
.../streams/pig/StreamsProcessDocumentExec.java | 11 -
.../streams/pig/StreamsSerializerExec.java | 16 +-
.../streams/pig/test/PigProcessDatumTest.java | 6 -
.../pig/test/PigProcessDocumentTest.java | 3 -
.../streams/pig/test/PigSerializerTest.java | 12 +-
.../src/test/resources/pigserializertest.pig | 2 +-
149 files changed, 5268 insertions(+), 4337 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/a6761f07/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/processor/GooglePlusTypeConverter.java
----------------------------------------------------------------------