streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sblack...@apache.org
Subject [1/3] incubator-streams git commit: Merge pull request #4 from apache/master
Date Fri, 19 Jun 2015 21:38:25 GMT
Repository: incubator-streams
Updated Branches:
  refs/heads/master 7b4a37293 -> 0db84e4fb


Merge pull request #4 from apache/master

update to 0.3

Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/701165f5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/701165f5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/701165f5

Branch: refs/heads/master
Commit: 701165f5645aaf727619d183c2caa54a53faf028
Parents: 90a96df 6a05779
Author: Steve Blackmon <sblackmon@apache.org>
Authored: Sat May 2 13:08:39 2015 -0500
Committer: Steve Blackmon <sblackmon@apache.org>
Committed: Sat May 2 13:08:39 2015 -0500

----------------------------------------------------------------------
 CHANGELOG.md                                    |    51 +-
 NOTICE                                          |     2 +-
 README.md                                       |    31 +-
 pom.xml                                         |   301 +-
 src/site/site.xml                               |    29 +
 streams-components/pom.xml                      |     8 +-
 streams-components/streams-converters/pom.xml   |     4 +-
 .../converter/ActivityConverterProcessor.java   |   201 +-
 .../converter/ActivityConverterUtil.java        |   233 +
 .../BaseObjectNodeActivityConverter.java        |     2 +-
 .../converter/BaseStringActivityConverter.java  |     2 +-
 .../converter/HoconConverterProcessor.java      |    76 +
 .../streams/converter/HoconConverterUtil.java   |   101 +
 .../converter/TypeConverterProcessor.java       |     2 -
 .../BaseActivityConverterProcessorTest.java     |     2 +-
 .../CustomActivityConverterProcessorTest.java   |     2 +-
 .../test/HoconConverterProcessorTest.java       |   117 +
 .../converter/test/HoconConverterTest.java      |    94 +
 .../NoConfigActivityConverterProcessorTest.java |     2 +-
 .../src/test/resources/test1.conf               |     2 +
 .../src/test/resources/test2.conf               |     4 +
 .../src/test/resources/test3a.conf              |     4 +
 .../src/test/resources/test3b.conf              |     2 +
 streams-components/streams-filters/README.md    |     8 +
 streams-components/streams-filters/pom.xml      |    72 +
 .../filters/VerbDefinitionDropFilter.java       |    90 +
 .../filters/VerbDefinitionKeepFilter.java       |    89 +
 .../filters/test/VerbDefinitionFilterTest.java  |   259 +
 .../src/test/resources/actor.json               |     9 +
 .../src/test/resources/follow.json              |    12 +
 .../src/test/resources/object.json              |     9 +
 .../src/test/resources/post.json                |    12 +
 .../src/test/resources/provider.json            |     9 +
 .../src/test/resources/targetrequired.json      |    12 +
 streams-components/streams-http/README.md       |     7 +
 streams-components/streams-http/pom.xml         |    19 +-
 .../components/http/HttpConfigurator.java       |    13 +
 .../persist/SimpleHTTPPostPersistWriter.java    |   206 +
 .../http/processor/SimpleHTTPGetProcessor.java  |    39 +-
 .../http/processor/SimpleHTTPPostProcessor.java |   278 +
 .../http/provider/SimpleHTTPGetProvider.java    |   174 +-
 .../http/provider/SimpleHttpProvider.java       |   340 +
 .../components/http/HttpConfiguration.json      |    14 +-
 .../http/HttpPersistWriterConfiguration.json    |    18 +
 .../java/SimpleHTTPPostPersistWriterTest.java   |   138 +
 streams-config/pom.xml                          |     2 +-
 .../main/jsonschema/StreamsConfiguration.json   |     8 +
 streams-contrib/pom.xml                         |     4 +-
 streams-contrib/streams-amazon-aws/pom.xml      |     2 +-
 .../streams-persist-s3/pom.xml                  |     2 +-
 .../org/apache/streams/s3/S3Configurator.java   |    17 +-
 .../org/apache/streams/s3/S3PersistWriter.java  |     2 +-
 .../streams-persist-cassandra/pom.xml           |     2 +-
 streams-contrib/streams-persist-console/pom.xml |     2 +-
 .../streams-persist-elasticsearch/pom.xml       |     4 +-
 .../ElasticsearchMetadataUtil.java              |    12 +
 .../ElasticsearchPersistReader.java             |     3 +
 .../ElasticsearchPersistWriter.java             |    31 +-
 .../src/main/resources/reference.conf           |     9 +
 .../src/main/resources/reference.json           |     9 -
 .../streams-persist-filebuffer/README.md        |    12 +
 .../streams-persist-filebuffer/pom.xml          |   140 +
 .../filebuffer/FileBufferConfigurator.java      |    53 +
 .../filebuffer/FileBufferPersistReader.java     |   174 +
 .../filebuffer/FileBufferPersistWriter.java     |   111 +
 .../streams/file/FileBufferConfiguration.json   |    17 +
 .../filebuffer/test/FileBufferPersistIT.java    |   129 +
 .../filebuffer/test/TestFileBufferPersist.java  |    74 +
 streams-contrib/streams-persist-graph/README.md |    57 +
 streams-contrib/streams-persist-graph/pom.xml   |   123 +
 .../org/apache/streams/graph/GraphHelper.java   |    41 +
 .../streams/graph/GraphPersistWriter.java       |   216 +
 .../apache/streams/graph/GraphVertexReader.java |   110 +
 .../streams/graph/neo4j/CypherGraphHelper.java  |   193 +
 .../streams/graph/GraphConfiguration.json       |    22 +
 .../graph/GraphEdgeWriterConfiguration.json     |    33 +
 .../streams/graph/GraphReaderConfiguration.json |    20 +
 .../graph/GraphVertexWriterConfiguration.json   |    33 +
 .../streams/graph/GraphWriterConfiguration.json |    21 +
 .../graph/neo4j/CypherQueryResponse.json        |    43 +
 .../graph/test/TestNeo4jVertexReader.java       |    81 +
 .../src/test/resources/sampleReaderResult.json  |   119 +
 streams-contrib/streams-persist-hbase/pom.xml   |     2 +-
 streams-contrib/streams-persist-hdfs/pom.xml    |    35 +-
 .../org/apache/streams/hdfs/HdfsConstants.java  |    31 +
 .../streams/hdfs/WebHdfsPersistReader.java      |    12 +-
 .../streams/hdfs/WebHdfsPersistReaderTask.java  |    88 +-
 .../streams/hdfs/WebHdfsPersistWriter.java      |    49 +-
 .../apache/streams/hdfs/HdfsConfiguration.json  |    20 +
 .../streams/hdfs/test/TestHdfsPersist.java      |   119 +
 streams-contrib/streams-persist-kafka/pom.xml   |     2 +-
 streams-contrib/streams-persist-mongo/pom.xml   |    56 +-
 .../streams/mongo/MongoPersistReader.java       |    34 +-
 .../streams/mongo/MongoPersistWriter.java       |    17 +-
 .../src/main/resources/reference.conf           |     8 +
 .../src/main/resources/reference.json           |     8 -
 .../streams/mongo/test/TestMongoPersist.java    |   118 +
 .../streams-processor-jackson/pom.xml           |     2 +-
 streams-contrib/streams-processor-json/pom.xml  |     2 +-
 .../apache/streams/json/JsonPathExtractor.java  |     2 +-
 .../org/apache/streams/json/JsonPathFilter.java |     2 +-
 .../json/test/JsonPathExtractorTwitterTest.java |    92 -
 .../src/test/resources/tweet.json               |     1 -
 .../streams-processor-peoplepattern/pom.xml     |     2 +-
 .../resources/templates/peoplepatternactor.json |     3 +
 streams-contrib/streams-processor-regex/pom.xml |     2 +-
 streams-contrib/streams-processor-urls/pom.xml  |     2 +-
 .../streams-provider-datasift/pom.xml           |     2 +-
 .../datasift/provider/DatasiftPushProvider.java |   227 +-
 .../DatasiftInteractionActivitySerializer.java  |     8 +-
 .../DatasiftTwitterActivitySerializer.java      |     4 +-
 .../apache/streams/datasift/DatasiftPush.json   |    35 -
 .../streams/datasift/DatasiftWebhookData.json   |    35 +
 .../com/datasift/test/DatasiftSerDeTest.java    |     6 +-
 .../DatasiftActivitySerializerTest.java         |     8 +-
 .../serializer/DatasiftEventClassifierTest.java |     6 +-
 ...DatasiftInstagramActivitySerializerTest.java |    17 +-
 ...tasiftInteractionActivitySerializerTest.java |    17 +-
 .../DatasiftTwitterActivitySerializerTest.java  |    19 +-
 .../src/test/resources/amazon_datasift_json.txt |    10 -
 .../src/test/resources/blog_datasift_json.txt   |   719 -
 .../src/test/resources/board_datasift_json.txt  |  4160 --
 .../test/resources/facebook_datasift_json.txt   |  1843 -
 .../test/resources/instagram_datasift_json.txt  |    25 -
 .../src/test/resources/part-r-00000.json        |   862 -
 .../resources/rand_sample_datasift_json.txt     |  1547 -
 .../resources/random_sample_datasift_json.txt   |  1547 -
 .../src/test/resources/reddit_datasift_json.txt |    33 -
 .../test/resources/twitter_datasift_json.txt    |  1000 -
 .../test/resources/wikipedia_datasift_json.txt  |   252 -
 .../test/resources/youtube_datasift_json.txt    |     7 -
 .../streams-provider-facebook/pom.xml           |     2 +-
 .../api/FacebookPageActivitySerializer.java     |     2 +-
 .../api/FacebookPostActivitySerializer.java     |     2 +-
 .../processor/FacebookTypeConverter.java        |     2 +-
 .../provider/FacebookFriendFeedProvider.java    |     4 +-
 .../provider/FacebookFriendUpdatesProvider.java |     4 +-
 .../FacebookUserInformationProvider.java        |     4 +-
 .../provider/FacebookUserstreamProvider.java    |     4 +-
 .../serializer/FacebookActivityUtil.java        |    12 +-
 .../test/FacebookActivityActorSerDeTest.java    |    11 +-
 .../test/FacebookActivitySerDeTest.java         |     5 +
 .../facebook/test/FacebookPageSerDeTest.java    |     4 +
 .../facebook/test/FacebookPostSerDeTest.java    |     4 +
 .../streams/facebook/test/SimplePageTest.java   |    11 +-
 .../src/test/resources/Facebook.json            |   250 -
 .../src/test/resources/testpage.json            |     1 -
 .../src/test/resources/testpost.json            |   162 -
 .../gnip-edc-facebook/pom.xml                   |     2 +-
 .../test/FacebookEDCAsActivityTest.java         |    14 +-
 .../facebook/test/FacebookEDCSerDeTest.java     |    20 +-
 .../src/test/resources/FacebookEDC.xml          |    71 -
 .../gnip-edc-flickr/pom.xml                     |     2 +-
 .../flickr/test/FlickrEDCAsActivityTest.java    |    16 +-
 .../gnip/flickr/test/FlickrEDCSerDeTest.java    |    17 +-
 .../src/test/resources/FlickrEDC.xml            |    64 -
 .../gnip-edc-googleplus/pom.xml                 |    42 +-
 .../com/gplus/api/GPlusEDCAsActivityTest.java   |     8 +-
 .../src/test/resources/GPlusEDCFixed.json       |   100 -
 .../gnip-edc-instagram/pom.xml                  |     2 +-
 .../com/instagram/test/InstagramSerDeTest.java  |     5 +
 .../src/test/resources/instagram_jsons.txt      |     6 -
 .../gnip-edc-reddit/pom.xml                     |    46 +-
 .../reddit/api/RedditEDCAsActivityJSONTest.java |    10 +-
 .../src/test/resources/RedditEDC.json           |   100 -
 .../src/test/resources/RedditEDC.xml            |  5762 ---
 .../src/test/resources/RedditEDCFixed.json      |   100 -
 .../src/test/resources/RedditEDCFlattened.xml   |   100 -
 .../src/test/resources/redditTest.xml           |     1 -
 .../gnip-edc-youtube/pom.xml                    |     2 +-
 .../java/com/gnip/test/YouTubeEDCSerDeTest.java |    13 +-
 .../com/gnip/test/YoutubeEDCAsActivityTest.java |    13 +-
 .../src/test/resources/YoutubeEDC.xml           |     8 -
 .../gnip-powertrack/pom.xml                     |    16 +-
 streams-contrib/streams-provider-gnip/pom.xml   |     2 +-
 .../google-gmail/pom.xml                        |     2 +-
 .../GMailMessageActivitySerializer.java         |     7 +-
 .../gmail/test/GMailMessageSerDeTest.java       |    67 +
 .../google-gplus/pom.xml                        |     2 +-
 .../processor/GooglePlusTypeConverter.java      |     2 +-
 .../util/GPlusCommentDeserializer.java          |     2 +-
 .../serializer/util/GPlusEventClassifier.java   |     2 +-
 .../util/GPlusPersonDeserializer.java           |     2 +-
 .../serializer/util/GooglePlusActivityUtil.java |     5 +-
 .../src/main/resources/reference.conf           |     2 +
 .../gmail/test/GMailMessageSerDeTest.java       |    71 -
 .../gplus/GooglePlusCommentSerDeTest.java       |     6 +-
 .../google/gplus/GooglePlusPersonSerDeTest.java |     7 +-
 .../processor/GooglePlusActivitySerDeTest.java  |     7 +-
 .../processor/GooglePlusTypeConverterTest.java  |     7 +-
 .../TestGPlusUserActivityCollector.java         |     2 +-
 streams-contrib/streams-provider-google/pom.xml |     2 +-
 .../streams-provider-instagram/pom.xml          |     2 +-
 .../serializer/InstagramUserInfoSerializer.java |     2 +-
 .../serializer/util/InstagramActivityUtil.java  |    32 +-
 .../src/main/resources/reference.conf           |     2 +
 .../test/InstagramActivitySerDeTest.java        |     5 +
 .../src/test/resources/testMediaFeedObjects.txt |     2 -
 .../src/test/resources/testUserInfoData.txt     |     2 -
 .../src/test/resources/testtweets.txt           |   695 -
 .../streams-provider-moreover/pom.xml           |     2 +-
 .../MoreoverJsonActivitySerializerTest.java     |    13 +-
 .../data/MoreoverXmlActivitySerializerTest.java |     5 +
 .../org/apache/streams/data/moreover.json       | 39433 -----------------
 .../org/apache/streams/data/moreover.xml        |  1324 -
 streams-contrib/streams-provider-rss/pom.xml    |     2 +-
 .../serializer/SyndEntryActivitySerializer.java |     8 +-
 .../rss/provider/RssStreamProviderTaskTest.java |     2 +
 .../rss/provider/RssStreamProviderTest.java     |     7 +-
 .../streams/rss/test/RssTypeConverterTest.java  |     3 +
 .../test/SyndEntryActivitySerizlizerTest.java   |     7 +-
 .../src/test/resources/TestSyndEntryJson.txt    |    11 -
 .../test/resources/test_rss_xml/economist1.xml  |   233 -
 .../test/resources/test_rss_xml/economist2.xml  |  1069 -
 .../test_rss_xml/economistCombined.xml          |   221 -
 .../src/test/resources/top100.opml              |   110 -
 .../streams-provider-sysomos/pom.xml            |    16 +-
 .../sysomos/provider/ContentRequestBuilder.java |     2 +-
 .../sysomos/provider/SysomosProvider.java       |     8 +
 .../com/sysomos/test/SysomosJsonSerDeTest.java  |     8 +-
 .../com/sysomos/test/SysomosXmlSerDeTest.java   |     8 +-
 .../src/test/resources/sysomos_jsons.txt        |   101 -
 .../src/test/resources/sysomos_xmls.txt         |     6 -
 .../streams-provider-twitter/pom.xml            |    20 +-
 .../twitter/converter/StreamsTwitterMapper.java |    87 +
 .../converter/TwitterDateTimeFormat.java        |    34 +
 .../converter/TwitterDocumentClassifier.java    |    85 +
 .../TwitterFollowActivityConverter.java         |    84 +
 .../TwitterJsonDeleteActivityConverter.java     |    89 +
 .../TwitterJsonRetweetActivityConverter.java    |    83 +
 .../TwitterJsonTweetActivityConverter.java      |    84 +
 .../TwitterJsonUserActivityConverter.java       |    82 +
 ...terJsonUserstreameventActivityConverter.java |   120 +
 .../converter/util/TwitterActivityUtil.java     |   349 +
 .../FetchAndReplaceTwitterProcessor.java        |     8 +-
 .../processor/TwitterEventProcessor.java        |   120 +-
 .../processor/TwitterProfileProcessor.java      |     2 +-
 .../twitter/processor/TwitterTypeConverter.java |   183 +-
 .../provider/TwitterEventClassifier.java        |    38 +-
 .../provider/TwitterFollowingProvider.java      |   137 +
 .../provider/TwitterFollowingProviderTask.java  |   160 +
 .../provider/TwitterFriendsProviderTask.java    |   181 +
 .../provider/TwitterStreamProcessor.java        |     2 +-
 .../TwitterUserInformationProvider.java         |     9 +-
 .../serializer/StreamsTwitterMapper.java        |    94 -
 .../TwitterJsonActivitySerializer.java          |    70 -
 .../TwitterJsonDeleteActivitySerializer.java    |    94 -
 .../TwitterJsonRetweetActivitySerializer.java   |    79 -
 .../TwitterJsonTweetActivitySerializer.java     |    77 -
 .../TwitterJsonUserActivitySerializer.java      |    78 -
 ...erJsonUserstreameventActivitySerializer.java |   115 -
 .../serializer/util/TwitterActivityUtil.java    |   336 -
 .../src/main/jsonschema/com/twitter/Follow.json |    17 +
 .../src/main/jsonschema/com/twitter/User.json   |   126 +
 .../src/main/jsonschema/com/twitter/tweet.json  |   125 +-
 .../src/main/resources/reference.conf           |     2 +
 .../streams/twitter/test/SimpleTweetTest.java   |   121 -
 .../twitter/test/TweetActivitySerDeTest.java    |   139 -
 .../streams/twitter/test/TweetSerDeTest.java    |   140 -
 .../test/TwitterActivityConvertersTest.java     |    86 +
 .../test/TwitterDocumentClassifierTest.java     |    84 +
 .../test/TwitterEventClassifierTest.java        |   100 -
 .../twitter/test/TwitterObjectMapperTest.java   |   137 +
 .../twitter/test/TwitterStreamProviderTest.java |    58 -
 .../src/test/resources/testtweets.txt           |   695 -
 .../src/test/resources/twitter_jsons.txt        |   695 -
 .../streams-provider-youtube/pom.xml            |     2 +-
 .../youtube/processor/YoutubeTypeConverter.java |    16 +-
 .../provider/YoutubeChannelDataCollector.java   |    98 +
 .../provider/YoutubeChannelProvider.java        |    38 +
 .../youtube/serializer/YoutubeActivityUtil.java |    46 +-
 .../serializer/YoutubeChannelDeserializer.java  |   150 +
 .../serializer/YoutubeEventClassifier.java      |     7 +-
 .../processor/YoutubeTypeConverterTest.java     |     2 +-
 .../YoutubeChannelDataCollectorTest.java        |   101 +
 .../serializer/YoutubeVideoSerDeTest.java       |     2 +-
 streams-core/pom.xml                            |     7 +-
 streams-monitoring/pom.xml                      |     2 +-
 .../impl/LogstashUdpMessagePersister.java       |   104 +
 .../tasks/BroadcastMonitorThread.java           |    37 +-
 .../jackson/MemoryUsageDeserializerTest.java    |     4 +-
 .../impl/LogstashUdpMessagePersisterTest.java   |    75 +
 .../activity-consumer/pom.xml                   |     2 +-
 .../activity-registration/pom.xml               |     2 +-
 .../activity-subscriber/pom.xml                 |     2 +-
 streams-osgi-components/pom.xml                 |     2 +-
 streams-pojo-extensions/pom.xml                 |     2 +-
 .../apache/streams/data/util/PropertyUtil.java  |   123 +
 streams-pojo/pom.xml                            |    96 +-
 .../streams/jackson/StreamsJacksonMapper.java   |     8 +-
 streams-pojo/src/main/jsonschema/activity.json  |   107 +
 .../src/main/jsonschema/collection.json         |    47 +
 .../src/main/jsonschema/media_link.json         |    34 +
 streams-pojo/src/main/jsonschema/object.json    |    96 +
 .../src/main/jsonschema/objectTypes/alert.json  |    19 +
 .../jsonschema/objectTypes/application.json     |    19 +
 .../main/jsonschema/objectTypes/article.json    |    19 +
 .../src/main/jsonschema/objectTypes/audio.json  |    19 +
 .../src/main/jsonschema/objectTypes/badge.json  |    19 +
 .../src/main/jsonschema/objectTypes/binary.json |    19 +
 .../main/jsonschema/objectTypes/bookmark.json   |    19 +
 .../main/jsonschema/objectTypes/comment.json    |    19 +
 .../src/main/jsonschema/objectTypes/device.json |    19 +
 .../src/main/jsonschema/objectTypes/event.json  |    51 +
 .../src/main/jsonschema/objectTypes/file.json   |    25 +
 .../src/main/jsonschema/objectTypes/folder.json |    19 +
 .../src/main/jsonschema/objectTypes/game.json   |    19 +
 .../src/main/jsonschema/objectTypes/group.json  |    19 +
 .../src/main/jsonschema/objectTypes/image.json  |    22 +
 .../src/main/jsonschema/objectTypes/issue.json  |    25 +
 .../src/main/jsonschema/objectTypes/job.json    |    19 +
 .../src/main/jsonschema/objectTypes/list.json   |    28 +
 .../src/main/jsonschema/objectTypes/note.json   |    19 +
 .../src/main/jsonschema/objectTypes/offer.json  |    19 +
 .../jsonschema/objectTypes/organization.json    |    19 +
 .../src/main/jsonschema/objectTypes/page.json   |    19 +
 .../main/jsonschema/objectTypes/permission.json |    36 +
 .../src/main/jsonschema/objectTypes/person.json |    25 +
 .../jsonschema/objectTypes/photo-album.json     |    19 +
 .../src/main/jsonschema/objectTypes/photo.json  |    23 +
 .../src/main/jsonschema/objectTypes/place.json  |    43 +
 .../main/jsonschema/objectTypes/playlist.json   |    19 +
 .../main/jsonschema/objectTypes/process.json    |    19 +
 .../main/jsonschema/objectTypes/product.json    |    25 +
 .../main/jsonschema/objectTypes/property.json   |    48 +
 .../main/jsonschema/objectTypes/question.json   |    28 +
 .../src/main/jsonschema/objectTypes/review.json |    22 +
 .../src/main/jsonschema/objectTypes/role.json   |    25 +
 .../main/jsonschema/objectTypes/service.json    |    19 +
 .../src/main/jsonschema/objectTypes/song.json   |    19 +
 .../src/main/jsonschema/objectTypes/status.json |    19 +
 .../src/main/jsonschema/objectTypes/task.json   |    44 +
 .../src/main/jsonschema/objectTypes/team.json   |    19 +
 .../src/main/jsonschema/objectTypes/video.json  |    19 +
 .../org/apache/streams/pojo/json/activity.json  |   107 -
 .../apache/streams/pojo/json/collection.json    |    47 -
 .../apache/streams/pojo/json/media_link.json    |    34 -
 .../org/apache/streams/pojo/json/object.json    |    96 -
 .../streams/pojo/json/objectTypes/article.json  |    19 -
 .../streams/pojo/json/objectTypes/audio.json    |    19 -
 .../streams/pojo/json/objectTypes/bookmark.json |    19 -
 .../streams/pojo/json/objectTypes/comment.json  |    19 -
 .../streams/pojo/json/objectTypes/event.json    |    25 -
 .../streams/pojo/json/objectTypes/file.json     |    19 -
 .../streams/pojo/json/objectTypes/folder.json   |    19 -
 .../streams/pojo/json/objectTypes/group.json    |    19 -
 .../streams/pojo/json/objectTypes/list.json     |    28 -
 .../streams/pojo/json/objectTypes/note.json     |    19 -
 .../streams/pojo/json/objectTypes/person.json   |    25 -
 .../pojo/json/objectTypes/photo-album.json      |    19 -
 .../streams/pojo/json/objectTypes/photo.json    |    23 -
 .../streams/pojo/json/objectTypes/place.json    |    24 -
 .../streams/pojo/json/objectTypes/playlist.json |    19 -
 .../streams/pojo/json/objectTypes/product.json  |    19 -
 .../streams/pojo/json/objectTypes/property.json |    48 -
 .../streams/pojo/json/objectTypes/review.json   |    19 -
 .../streams/pojo/json/objectTypes/service.json  |    19 -
 .../streams/pojo/json/objectTypes/song.json     |    19 -
 .../streams/pojo/json/objectTypes/status.json   |    19 -
 .../streams/pojo/json/objectTypes/video.json    |    19 -
 .../streams/pojo/json/verbs/favorite.json       |    24 -
 .../apache/streams/pojo/json/verbs/follow.json  |    24 -
 .../apache/streams/pojo/json/verbs/join.json    |    24 -
 .../apache/streams/pojo/json/verbs/like.json    |    24 -
 .../streams/pojo/json/verbs/make-friend.json    |    24 -
 .../apache/streams/pojo/json/verbs/play.json    |    24 -
 .../apache/streams/pojo/json/verbs/post.json    |    24 -
 .../streams/pojo/json/verbs/rsvp-maybe.json     |    24 -
 .../apache/streams/pojo/json/verbs/rsvp-no.json |    24 -
 .../streams/pojo/json/verbs/rsvp-yes.json       |    24 -
 .../apache/streams/pojo/json/verbs/save.json    |    24 -
 .../apache/streams/pojo/json/verbs/share.json   |    24 -
 .../org/apache/streams/pojo/json/verbs/tag.json |    24 -
 .../apache/streams/pojo/json/verbs/update.json  |    34 -
 .../src/main/jsonschema/verbs/accept.json       |    24 +
 .../src/main/jsonschema/verbs/access.json       |    24 +
 .../src/main/jsonschema/verbs/acknowledge.json  |    24 +
 streams-pojo/src/main/jsonschema/verbs/add.json |    24 +
 .../src/main/jsonschema/verbs/agree.json        |    24 +
 .../src/main/jsonschema/verbs/append.json       |    24 +
 .../src/main/jsonschema/verbs/approve.json      |    24 +
 .../src/main/jsonschema/verbs/archive.json      |    24 +
 .../src/main/jsonschema/verbs/assign.json       |    24 +
 streams-pojo/src/main/jsonschema/verbs/at.json  |    24 +
 .../src/main/jsonschema/verbs/attach.json       |    24 +
 .../src/main/jsonschema/verbs/attend.json       |    24 +
 .../src/main/jsonschema/verbs/author.json       |    24 +
 .../src/main/jsonschema/verbs/authorize.json    |    24 +
 .../src/main/jsonschema/verbs/borrow.json       |    24 +
 .../src/main/jsonschema/verbs/build.json        |    24 +
 .../src/main/jsonschema/verbs/cancel.json       |    24 +
 .../src/main/jsonschema/verbs/checkin.json      |    24 +
 .../src/main/jsonschema/verbs/close.json        |    24 +
 .../src/main/jsonschema/verbs/complete.json     |    24 +
 .../src/main/jsonschema/verbs/confirm.json      |    24 +
 .../src/main/jsonschema/verbs/consume.json      |    24 +
 .../src/main/jsonschema/verbs/create.json       |    24 +
 .../src/main/jsonschema/verbs/delete.json       |    24 +
 .../src/main/jsonschema/verbs/deliver.json      |    24 +
 .../src/main/jsonschema/verbs/deny.json         |    24 +
 .../src/main/jsonschema/verbs/disagree.json     |    24 +
 .../src/main/jsonschema/verbs/dislike.json      |    24 +
 .../src/main/jsonschema/verbs/experience.json   |    24 +
 .../src/main/jsonschema/verbs/favorite.json     |    24 +
 .../src/main/jsonschema/verbs/find.json         |    24 +
 .../jsonschema/verbs/flag-as-inappropriate.json |    24 +
 .../src/main/jsonschema/verbs/follow.json       |    24 +
 .../src/main/jsonschema/verbs/give.json         |    24 +
 .../src/main/jsonschema/verbs/host.json         |    24 +
 .../src/main/jsonschema/verbs/ignore.json       |    24 +
 .../src/main/jsonschema/verbs/insert.json       |    24 +
 .../src/main/jsonschema/verbs/install.json      |    24 +
 .../src/main/jsonschema/verbs/interact.json     |    24 +
 .../src/main/jsonschema/verbs/invite.json       |    24 +
 .../src/main/jsonschema/verbs/join.json         |    24 +
 .../src/main/jsonschema/verbs/leave.json        |    24 +
 .../src/main/jsonschema/verbs/like.json         |    24 +
 .../src/main/jsonschema/verbs/listen.json       |    24 +
 .../src/main/jsonschema/verbs/lose.json         |    24 +
 .../src/main/jsonschema/verbs/make-friend.json  |    24 +
 .../src/main/jsonschema/verbs/open.json         |    24 +
 .../src/main/jsonschema/verbs/play.json         |    24 +
 .../src/main/jsonschema/verbs/post.json         |    24 +
 .../src/main/jsonschema/verbs/present.json      |    24 +
 .../src/main/jsonschema/verbs/purchase.json     |    24 +
 .../src/main/jsonschema/verbs/qualify.json      |    24 +
 .../src/main/jsonschema/verbs/read.json         |    24 +
 .../src/main/jsonschema/verbs/receive.json      |    24 +
 .../src/main/jsonschema/verbs/reject.json       |    24 +
 .../main/jsonschema/verbs/remove-friend.json    |    24 +
 .../src/main/jsonschema/verbs/remove.json       |    24 +
 .../src/main/jsonschema/verbs/replace.json      |    24 +
 .../main/jsonschema/verbs/request-friend.json   |    24 +
 .../src/main/jsonschema/verbs/request.json      |    24 +
 .../src/main/jsonschema/verbs/resolve.json      |    24 +
 .../src/main/jsonschema/verbs/retract.json      |    24 +
 .../src/main/jsonschema/verbs/return.json       |    24 +
 .../src/main/jsonschema/verbs/rsvp-maybe.json   |    24 +
 .../src/main/jsonschema/verbs/rsvp-no.json      |    24 +
 .../src/main/jsonschema/verbs/rsvp-yes.json     |    24 +
 .../src/main/jsonschema/verbs/satisfy.json      |    24 +
 .../src/main/jsonschema/verbs/save.json         |    24 +
 .../src/main/jsonschema/verbs/schedule.json     |    24 +
 .../src/main/jsonschema/verbs/search.json       |    24 +
 .../src/main/jsonschema/verbs/sell.json         |    24 +
 .../src/main/jsonschema/verbs/send.json         |    24 +
 .../src/main/jsonschema/verbs/share.json        |    24 +
 .../src/main/jsonschema/verbs/sponsor.json      |    24 +
 .../src/main/jsonschema/verbs/start.json        |    24 +
 .../main/jsonschema/verbs/stop-following.json   |    24 +
 .../src/main/jsonschema/verbs/submit.json       |    24 +
 streams-pojo/src/main/jsonschema/verbs/tag.json |    24 +
 .../src/main/jsonschema/verbs/terminate.json    |    24 +
 streams-pojo/src/main/jsonschema/verbs/tie.json |    24 +
 .../src/main/jsonschema/verbs/unfavorite.json   |    24 +
 .../src/main/jsonschema/verbs/unlike.json       |    24 +
 .../src/main/jsonschema/verbs/unsatisfy.json    |    24 +
 .../src/main/jsonschema/verbs/unsave.json       |    24 +
 .../src/main/jsonschema/verbs/unshare.json      |    24 +
 .../src/main/jsonschema/verbs/update.json       |    34 +
 streams-pojo/src/main/jsonschema/verbs/use.json |    24 +
 .../src/main/jsonschema/verbs/watch.json        |    24 +
 streams-pojo/src/main/jsonschema/verbs/win.json |    24 +
 streams-pojo/src/main/xmlschema/activity.xsd    |    94 +
 .../org/apache/streams/pojo/xml/activity.xsd    |    94 -
 streams-pojo/src/site/markdown/index.md         |    31 +
 .../data/data/util/ActivitySerDeTest.java       |    98 +
 .../src/test/resources/activities/accept.json   |    16 +
 .../src/test/resources/activities/access.json   |    17 +
 .../test/resources/activities/acknowledge.json  |    16 +
 .../src/test/resources/activities/add.json      |    21 +
 .../src/test/resources/activities/agree.json    |    15 +
 .../src/test/resources/activities/append.json   |    16 +
 .../src/test/resources/activities/approve.json  |    20 +
 .../src/test/resources/activities/archive.json  |    15 +
 .../src/test/resources/activities/assign.json   |    20 +
 .../src/test/resources/activities/at.json       |    15 +
 .../src/test/resources/activities/attach.json   |    20 +
 .../src/test/resources/activities/attend.json   |    15 +
 .../src/test/resources/activities/author.json   |    15 +
 .../test/resources/activities/authorize.json    |    23 +
 .../src/test/resources/activities/borrow.json   |    21 +
 .../src/test/resources/activities/build.json    |    16 +
 .../src/test/resources/activities/cancel.json   |    16 +
 .../src/test/resources/activities/checkin.json  |    16 +
 .../src/test/resources/activities/close.json    |    16 +
 .../src/test/resources/activities/complete.json |    16 +
 .../src/test/resources/activities/confirm.json  |    17 +
 .../src/test/resources/activities/consume.json  |    16 +
 .../src/test/resources/activities/create.json   |    15 +
 .../src/test/resources/activities/delete.json   |    16 +
 .../src/test/resources/activities/deliver.json  |    20 +
 .../src/test/resources/activities/deny.json     |    23 +
 .../src/test/resources/activities/disagree.json |    30 +
 .../src/test/resources/activities/dislike.json  |    15 +
 .../test/resources/activities/experience.json   |    16 +
 .../src/test/resources/activities/favorite.json |    15 +
 .../src/test/resources/activities/find.json     |    19 +
 .../activities/flag-as-inappropriate.json       |    24 +
 .../src/test/resources/activities/follow.json   |    15 +
 .../src/test/resources/activities/give.json     |    28 +
 .../src/test/resources/activities/host.json     |    15 +
 .../src/test/resources/activities/ignore.json   |    15 +
 .../src/test/resources/activities/insert.json   |    19 +
 .../src/test/resources/activities/install.json  |    18 +
 .../src/test/resources/activities/interact.json |    16 +
 .../src/test/resources/activities/invite.json   |    19 +
 .../src/test/resources/activities/join.json     |    15 +
 .../src/test/resources/activities/leave.json    |    15 +
 .../src/test/resources/activities/like.json     |    22 +
 .../src/test/resources/activities/listen.json   |    15 +
 .../src/test/resources/activities/lose.json     |    15 +
 .../test/resources/activities/make-friend.json  |    15 +
 .../src/test/resources/activities/open.json     |    15 +
 .../src/test/resources/activities/play.json     |    15 +
 .../src/test/resources/activities/post.json     |    25 +
 .../src/test/resources/activities/present.json  |    15 +
 .../src/test/resources/activities/purchase.json |    16 +
 .../src/test/resources/activities/qualify.json  |    15 +
 .../src/test/resources/activities/read.json     |    16 +
 .../src/test/resources/activities/receive.json  |    16 +
 .../src/test/resources/activities/reject.json   |    15 +
 .../resources/activities/remove-friend.json     |    15 +
 .../src/test/resources/activities/remove.json   |    23 +
 .../src/test/resources/activities/replace.json  |    19 +
 .../resources/activities/request-friend.json    |    16 +
 .../src/test/resources/activities/request.json  |    23 +
 .../src/test/resources/activities/resolve.json  |    15 +
 .../src/test/resources/activities/retract.json  |    26 +
 .../src/test/resources/activities/return.json   |    19 +
 .../test/resources/activities/rsvp-maybe.json   |    16 +
 .../src/test/resources/activities/rsvp-no.json  |    16 +
 .../src/test/resources/activities/rsvp-yes.json |    16 +
 .../src/test/resources/activities/satisfy.json  |    21 +
 .../src/test/resources/activities/save.json     |    20 +
 .../src/test/resources/activities/schedule.json |    15 +
 .../src/test/resources/activities/search.json   |    21 +
 .../src/test/resources/activities/sell.json     |    19 +
 .../src/test/resources/activities/send.json     |    19 +
 .../src/test/resources/activities/share.json    |    16 +
 .../src/test/resources/activities/sponsor.json  |    17 +
 .../src/test/resources/activities/start.json    |    15 +
 .../resources/activities/stop-following.json    |    15 +
 .../src/test/resources/activities/submit.json   |    15 +
 .../src/test/resources/activities/tag.json      |    19 +
 .../test/resources/activities/terminate.json    |    15 +
 .../src/test/resources/activities/tie.json      |    24 +
 .../test/resources/activities/unfavorite.json   |    15 +
 .../src/test/resources/activities/unlike.json   |    15 +
 .../test/resources/activities/unsatisfy.json    |    20 +
 .../src/test/resources/activities/unsave.json   |    15 +
 .../src/test/resources/activities/unshare.json  |    15 +
 .../src/test/resources/activities/update.json   |    15 +
 .../src/test/resources/activities/use.json      |    15 +
 .../src/test/resources/activities/watch.json    |    16 +
 .../src/test/resources/activities/win.json      |    15 +
 streams-runtimes/pom.xml                        |     3 +-
 .../streams-runtime-dropwizard/pom.xml          |   257 +
 .../dropwizard/GenericWebhookResource.java      |   257 +
 .../dropwizard/StreamDropwizardBuilder.java     |    55 +
 .../streams/dropwizard/StreamsApplication.java  |   191 +
 .../dropwizard/StreamsDropwizardModule.java     |    52 +
 .../streams/dropwizard/GenericWebhookData.json  |    35 +
 .../StreamsDropwizardConfiguration.json         |    13 +
 .../test/GenericWebhookResourceTest.java        |    99 +
 .../dropwizard/test/StreamsApplicationIT.java   |    48 +
 .../dropwizard/test/TestStreamsApplication.java |    27 +
 .../src/test/resources/configuration.yml        |    18 +
 streams-runtimes/streams-runtime-local/pom.xml  |     2 +-
 .../local/builders/LocalStreamBuilder.java      |    14 +-
 .../streams/local/queues/ThroughputQueue.java   |     4 +-
 .../streams/local/tasks/BaseStreamsTask.java    |     2 +-
 .../streams/local/tasks/StreamsMergeTask.java   |     2 +-
 .../local/tasks/StreamsPersistWriterTask.java   |     6 +-
 .../local/tasks/StreamsProviderTask.java        |    10 +-
 .../local/builders/LocalStreamBuilderTest.java  |    41 +-
 .../queues/ThroughputQueueSingleThreadTest.java |    21 +-
 .../streams/local/tasks/BasicTasksTest.java     |     4 +-
 streams-runtimes/streams-runtime-pig/pom.xml    |     2 +-
 .../streams/pig/StreamsComponentFactory.java    |     9 +-
 .../streams/pig/StreamsProcessDatumExec.java    |    10 +-
 .../streams/pig/StreamsSerializerExec.java      |    84 -
 .../streams/pig/test/PigConverterTest.java      |    56 +
 .../streams/pig/test/PigProcessDatumTest.java   |     7 +-
 .../pig/test/PigProcessDocumentTest.java        |     3 -
 .../streams/pig/test/PigSerializerTest.java     |    63 -
 .../src/test/resources/convertertestin.txt      |     1 +
 .../src/test/resources/convertertestout.txt     |     1 +
 .../src/test/resources/pigconvertertest.pig     |    24 +
 .../test/resources/pigprocessdatumcopytest.pig  |    19 +
 .../src/test/resources/pigprocessdatumtest.pig  |    19 +
 .../resources/pigprocessdocumentappendtest.pig  |    19 +
 .../test/resources/pigprocessdocumenttest.pig   |    19 +
 .../src/test/resources/pigserializertest.pig    |     7 -
 .../src/test/resources/serializertestin.txt     |     1 -
 .../src/test/resources/serializertestout.txt    |     1 -
 streams-runtimes/streams-runtime-storm/pom.xml  |     2 +-
 streams-runtimes/streams-runtime-webapp/pom.xml |     2 +-
 streams-util/pom.xml                            |     2 +-
 streams-verbs/README.md                         |    20 +
 streams-verbs/pom.xml                           |   172 +
 .../verbs/ObjectCombinationGenericOrdering.java |    74 +
 .../ObjectCombinationSpecificOrdering.java      |    82 +
 .../streams/verbs/VerbDefinitionMatchUtil.java  |    53 +
 .../streams/verbs/VerbDefinitionResolver.java   |   112 +
 .../verbs/VerbDefinitionTemplateUtil.java       |    63 +
 .../src/main/jsonschema/verb-definition.json    |    99 +
 streams-verbs/src/main/resources/delete.json    |    19 +
 streams-verbs/src/main/resources/follow.json    |    19 +
 streams-verbs/src/main/resources/post.json      |    19 +
 streams-verbs/src/main/resources/share.json     |    19 +
 .../ObjectCombinationGenericOrderingTest.java   |    41 +
 .../ObjectCombinationSpecificOrderingTest.java  |    50 +
 .../verbs/VerbDefinitionResolverTest.java       |   109 +
 .../verbs/VerbDefinitionTemplateTest.java       |    86 +
 .../streams/verbs/VerbDefinitionTest.java       |    63 +
 streams-verbs/src/test/resources/activities.txt |     4 +
 streams-verbs/src/test/resources/actor.json     |     9 +
 streams-verbs/src/test/resources/do.json        |    14 +
 streams-verbs/src/test/resources/follow.json    |    12 +
 streams-verbs/src/test/resources/nofields.json  |    15 +
 streams-verbs/src/test/resources/object.json    |     9 +
 streams-verbs/src/test/resources/post.json      |    15 +
 streams-verbs/src/test/resources/provider.json  |     9 +
 624 files changed, 16132 insertions(+), 67966 deletions(-)
----------------------------------------------------------------------




Mime
View raw message