streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reba...@apache.org
Subject [1/6] incubator-streams git commit: Merge pull request #19 from apache/master
Date Mon, 23 Feb 2015 22:54:07 GMT
Repository: incubator-streams
Updated Branches:
  refs/heads/master 363975fb8 -> d3a17609c


Merge pull request #19 from apache/master

Apache Master Merge 2015/02/03

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

Branch: refs/heads/master
Commit: 83bc516f4b00d44d0d43f07a1735a697be6b29db
Parents: ce67d58 e117557
Author: Ryan Ebanks <rbnks@users.noreply.github.com>
Authored: Tue Feb 3 15:07:01 2015 -0600
Committer: Ryan Ebanks <rbnks@users.noreply.github.com>
Committed: Tue Feb 3 15:07:01 2015 -0600

----------------------------------------------------------------------
 .gitignore                                      |    2 +
 CHANGELOG.md                                    |    7 +
 README.md                                       |   52 +
 README.txt                                      |   52 -
 pom.xml                                         |  396 ++-
 poms/compiled/pom.xml                           |    2 +-
 poms/pom.xml                                    |    2 +-
 poms/wrappers/pom.xml                           |   11 +-
 provision/pom.xml                               |    2 +-
 runner/bundles/downloaded_bundles.properties    |   25 -
 .../org.apache.felix.gogo.command_0.12.0.jar    |  Bin 51746 -> 0 bytes
 .../org.apache.felix.gogo.runtime_0.10.0.jar    |  Bin 66965 -> 0 bytes
 .../org.apache.felix.gogo.shell_0.10.0.jar      |  Bin 49004 -> 0 bytes
 runner/bundles/org.apache.felix.main_4.0.3.jar  |  Bin 493717 -> 0 bytes
 runner/deploy-pom.xml                           |   52 -
 runner/felix/config.ini                         |   34 -
 streams-components/README.md                    |   10 +
 streams-components/pom.xml                      |    7 +-
 streams-components/streams-converters/pom.xml   |  150 ++
 .../converter/ActivityConverterProcessor.java   |  262 ++
 .../converter/BaseDocumentClassifier.java       |   83 +
 .../BaseObjectNodeActivityConverter.java        |   93 +
 .../converter/BaseStringActivityConverter.java  |   93 +
 .../converter/TypeConverterProcessor.java       |   91 +
 .../streams/converter/TypeConverterUtil.java    |   70 +
 ...ActivityConverterProcessorConfiguration.json |   26 +
 .../BaseActivityConverterProcessorTest.java     |   92 +
 .../converter/test/CustomActivityConverter.java |   72 +
 .../CustomActivityConverterProcessorTest.java   |  103 +
 .../test/CustomDocumentClassifier.java          |   75 +
 .../streams/converter/test/CustomType.java      |   37 +
 .../test/TypeConverterProcessorTest.java        |  190 ++
 streams-components/streams-http/pom.xml         |    7 +-
 .../components/http/HttpConfiguration.json      |    5 +-
 .../http/HttpProcessorConfiguration.json        |    5 +-
 .../http/HttpProviderConfiguration.json         |    5 +-
 streams-config/README.md                        |    4 +
 streams-config/pom.xml                          |    9 +-
 .../main/jsonschema/ComponentConfiguration.json |    5 +-
 .../main/jsonschema/StreamsConfiguration.json   |    5 +-
 streams-contrib/README.md                       |    7 +
 streams-contrib/pom.xml                         |   10 +-
 streams-contrib/streams-amazon-aws/pom.xml      |    8 +-
 .../streams-persist-s3/README.md                |   18 +
 .../streams-persist-s3/pom.xml                  |    9 +-
 .../org/apache/streams/s3/S3Configurator.java   |    4 +-
 .../org/apache/streams/s3/S3PersistWriter.java  |   38 +-
 .../org/apache/streams/s3/S3Configuration.json  |    5 +-
 .../streams/s3/S3ReaderConfiguration.json       |    5 +-
 .../streams/s3/S3WriterConfiguration.json       |    5 +-
 .../apache/streams/s3/S3PersistWriterTest.java  |   80 +
 .../streams-persist-cassandra/pom.xml           |    9 +-
 .../streams-persist-console/README.md           |   16 +
 streams-contrib/streams-persist-console/pom.xml |   30 +-
 .../streams-persist-elasticsearch/pom.xml       |   26 +-
 .../ElasticsearchMetadataUtil.java              |   18 +
 .../ElasticsearchConfiguration.json             |    5 +-
 .../ElasticsearchReaderConfiguration.json       |    5 +-
 .../ElasticsearchWriterConfiguration.json       |    5 +-
 .../test/TestDatumFromMetadataProcessor.java    |   18 +
 .../test/TestDocumentToMetadataProcessor.java   |   18 +
 .../test/TestElasticsearchPersistWriter.java    |   18 +
 streams-contrib/streams-persist-hbase/README.md |   20 +
 streams-contrib/streams-persist-hbase/pom.xml   |   33 +-
 .../streams/hbase/HbaseConfiguration.json       |    5 +-
 streams-contrib/streams-persist-hdfs/README.md  |   29 +
 streams-contrib/streams-persist-hdfs/pom.xml    |   33 +-
 .../apache/streams/hdfs/HdfsConfiguration.json  |    5 +-
 .../streams/hdfs/HdfsReaderConfiguration.json   |    5 +-
 .../streams/hdfs/HdfsWriterConfiguration.json   |    5 +-
 streams-contrib/streams-persist-kafka/README.md |   14 +
 streams-contrib/streams-persist-kafka/pom.xml   |   26 +-
 .../streams/kafka/KafkaConfiguration.json       |    5 +-
 streams-contrib/streams-persist-mongo/README.md |   13 +-
 streams-contrib/streams-persist-mongo/pom.xml   |   26 +-
 .../streams/mongo/MongoConfiguration.json       |    5 +-
 .../streams-processor-jackson/README.md         |    5 +
 .../streams-processor-jackson/pom.xml           |   13 +-
 .../CleanAdditionalPropertiesProcessor.java     |   19 +
 .../streams/jackson/TypeConverterProcessor.java |    1 +
 .../streams-processor-json/README.md            |    5 +
 streams-contrib/streams-processor-json/pom.xml  |   13 +-
 .../streams-processor-lucene/pom.xml            |   19 +-
 .../lucene/LuceneSimpleTaggingProcessor.java    |   18 +
 .../lucene/LuceneTaggerConfiguration.json       |    5 +-
 .../lucene/TestLucenSimpleTaggingProcessor.java |   18 +
 .../streams-processor-peoplepattern/README.md   |   13 +
 .../streams-processor-peoplepattern/pom.xml     |   13 +-
 .../streams/peoplepattern/AccountType.json      |    5 +-
 .../streams/peoplepattern/Demographics.json     |    5 +-
 .../streams-processor-regex/README.md           |    5 +
 streams-contrib/streams-processor-regex/pom.xml |   13 +-
 streams-contrib/streams-processor-tika/pom.xml  |   19 +-
 .../org/apache/streams/tika/CategoryParser.java |   18 +
 .../org/apache/streams/tika/TikaProcessor.java  |   18 +
 .../apache/streams/tika/BoilerPipeArticle.json  |    5 +-
 .../streams-processor-urls/README.md            |    5 +
 streams-contrib/streams-processor-urls/pom.xml  |   30 +-
 .../org/apache/streams/urls/LinkDetails.json    |    5 +-
 .../streams/urls/TestLinkUnwinderProcessor.java |    8 +
 .../streams-provider-datasift/README.md         |   18 +
 .../streams-provider-datasift/pom.xml           |   26 +-
 .../streams/datasift/csdl/DatasiftCsdlUtil.java |   18 +
 .../DatasiftActivitySerializerProcessor.java    |    1 +
 .../DatasiftTypeConverterProcessor.java         |    1 +
 .../provider/DatasiftManagedSourceSetup.java    |   18 +
 .../datasift/provider/DatasiftPushProvider.java |    1 +
 .../provider/DatasiftStreamConfigurator.java    |    1 +
 .../provider/DatasiftStreamProvider.java        |    1 +
 .../streams/datasift/provider/ErrorHandler.java |    1 +
 .../streams/datasift/provider/Subscription.java |    1 +
 .../DatasiftInteractionActivitySerializer.java  |   18 +
 .../org/apache/streams/datasift/Datasift.json   |    6 +-
 .../streams/datasift/DatasiftConfiguration.json |    5 +-
 .../apache/streams/datasift/DatasiftPush.json   |    7 +-
 .../datasift/DatasiftPushConfiguration.json     |    5 +-
 .../datasift/DatasiftStreamConfiguration.json   |    5 +-
 .../datasift/facebook/DatasiftFacebook.json     |    9 +-
 .../datasift/instagram/DatasiftInstagram.json   |    9 +-
 .../interaction/DatasiftInteraction.json        |    7 +-
 .../datasift/twitter/DatasiftTwitter.json       |    9 +-
 .../datasift/twitter/DatasiftTwitterMedia.json  |    8 +-
 .../datasift/twitter/DatasiftTwitterUser.json   |    7 +-
 .../DatasiftActivitySerializerTest.java         |   18 +
 ...DatasiftInstagramActivitySerializerTest.java |   18 +
 ...tasiftInteractionActivitySerializerTest.java |   18 +
 .../DatasiftTwitterActivitySerializerTest.java  |   18 +
 .../streams-provider-facebook/README.md         |   17 +
 .../metadata/facebook_post.mup                  | 1297 +++++-----
 .../streams-provider-facebook/pom.xml           |   35 +-
 .../processor/FacebookTypeConverter.java        |    4 +-
 .../provider/FacebookDataCollector.java         |  141 ++
 .../facebook/provider/FacebookProvider.java     |  136 ++
 .../page/FacebookPageDataCollector.java         |   83 +
 .../provider/page/FacebookPageProvider.java     |   47 +
 .../pagefeed/FacebookDataCollector.java         |  138 --
 .../pagefeed/FacebookPageFeedDataCollector.java |   70 +-
 .../pagefeed/FacebookPageFeedProvider.java      |    5 +-
 .../provider/pagefeed/FacebookProvider.java     |  139 --
 .../serializer/FacebookActivityUtil.java        |    1 +
 .../FacebookStreamsPostSerializer.java          |   18 +
 .../streams/facebook/FacebookConfiguration.json |    5 +-
 .../FacebookUserInformationConfiguration.json   |    6 +-
 .../FacebookUserstreamConfiguration.json        |    5 +-
 .../org/apache/streams/facebook/Page.json       |  333 +--
 .../org/apache/streams/facebook/graph/Post.json |    6 +-
 .../provider/page/TestFacebookPageProvider.java |  186 ++
 .../facebook/provider/page/TestPage.java        |  125 +
 .../provider/pagefeed/TestFacebookProvider.java |    4 +-
 .../gnip-edc-facebook/pom.xml                   |   30 +-
 .../gnip-edc-flickr/pom.xml                     |   28 +-
 .../gnip-edc-googleplus/pom.xml                 |   30 +-
 .../gnip-edc-instagram/pom.xml                  |   28 +-
 .../jsonschema/com/instagram/Instagram.json     |    6 +-
 .../gnip-edc-reddit/pom.xml                     |   30 +-
 .../gnip-edc-youtube/pom.xml                    |   26 +-
 .../gnip-powertrack/pom.xml                     |   29 +-
 .../src/main/jsonschema/com/gnip/Gnip.json      |    8 +-
 .../src/main/xmlschema/com/gnip/binding.xjb     |   17 +
 .../src/main/xmlschema/com/gnip/entry.xsd       |   17 +
 streams-contrib/streams-provider-gnip/pom.xml   |   28 +-
 .../google-gmail/README.md                      |   14 +
 .../google-gmail/pom.xml                        |   28 +-
 .../com/google/gmail/GMailConfiguration.json    |    5 +-
 .../google-gplus/README.md                      |   22 +
 .../google-gplus/pom.xml                        |   28 +-
 .../gplus/provider/GPlusDataCollector.java      |   18 +
 .../provider/GPlusUserActivityCollector.java    |    1 +
 .../provider/GPlusUserActivityProvider.java     |   18 +
 .../gplus/provider/GPlusUserDataCollector.java  |   18 +
 .../gplus/provider/GPlusUserDataProvider.java   |   18 +
 .../com/google/gplus/GPlusConfiguration.json    |    6 +-
 .../provider/TestAbstractGPlusProvider.java     |   19 +
 .../TestGPlusUserActivityCollector.java         |   19 +
 .../provider/TestGPlusUserDataCollector.java    |   19 +
 .../util/GPlusEventClassifierTest.java          |    1 +
 streams-contrib/streams-provider-google/pom.xml |   28 +-
 .../streams-provider-instagram/README.md        |    1 +
 .../InstagramMediaDataActivitySerializer.mup    | 1697 ++++++-------
 .../streams-provider-instagram/pom.xml          |   28 +-
 .../serializer/InstagramUserInfoSerializer.java |   18 +
 .../com/instagram/InstagramConfiguration.json   |    5 +-
 .../InstagramUserInformationConfiguration.json  |    5 +-
 .../streams-provider-moreover/README.md         |   17 +
 .../streams-provider-moreover/pom.xml           |   28 +-
 .../main/jsonschema/com/moreover/Moreover.json  |    8 +-
 .../com/moreover/MoreoverConfiguration.json     |    5 +-
 .../main/xmlschema/com/moreover/articles10.xsd  |   17 +
 .../src/main/xmlschema/com/moreover/binding.xjb |   17 +
 .../streams/data/util/MoreoverTestUtil.java     |   19 +-
 .../streams-provider-rss/README.markdown        |    1 +
 streams-contrib/streams-provider-rss/pom.xml    |   28 +-
 .../main/jsonschema/RssStreamConfiguration.json |    5 +-
 .../src/main/xmlschema/contents.xsd             |   18 +-
 .../src/main/xmlschema/opml.xsd                 |   17 +
 .../rss/provider/RssStreamProviderTest.java     |   18 +
 .../streams-provider-sysomos/README.md          |   19 +
 .../streams-provider-sysomos/pom.xml            |   29 +-
 .../main/jsonschema/com/sysomos/Sysomos.json    |    8 +-
 .../com/sysomos/SysomosConfiguration.json       |    6 +-
 .../src/main/xmlschema/com/sysomos/binding.xjb  |   17 +
 .../src/main/xmlschema/com/sysomos/sysomos.xsd  |   18 +
 .../streams-provider-twitter/pom.xml            |   28 +-
 .../src/main/jsonschema/com/twitter/Delete.json |    6 +-
 .../main/jsonschema/com/twitter/FriendList.json |    6 +-
 .../main/jsonschema/com/twitter/Retweet.json    |    6 +-
 .../com/twitter/TwitterConfiguration.json       |    5 +-
 .../com/twitter/TwitterStreamConfiguration.json |    5 +-
 .../TwitterUserInformationConfiguration.json    |    5 +-
 .../jsonschema/com/twitter/UserstreamEvent.json |    6 +-
 .../src/main/jsonschema/com/twitter/tweet.json  |    5 +-
 streams-core/README.md                          |    4 +
 streams-core/pom.xml                            |   13 +-
 .../apache/streams/core/util/DatumUtils.java    |   12 +
 streams-monitoring/README.md                    |    4 +
 streams-monitoring/pom.xml                      |   13 +-
 .../persist/impl/SLF4JMessagePersister.java     |   18 +
 .../tasks/BroadcastMonitorThread.java           |    3 +
 .../org/apache/streams/pojo/json/Broadcast.json |   41 +-
 .../pojo/json/DatumStatusCounterBroadcast.json  |   43 +-
 .../streams/pojo/json/MemoryUsageBroadcast.json |   59 +-
 .../pojo/json/StreamsTaskCounterBroadcast.json  |   75 +-
 .../pojo/json/ThroughputQueueBroadcast.json     |   75 +-
 .../activity-consumer/osgi.bnd                  |    4 +
 .../activity-consumer/pom.xml                   |    8 +-
 .../spring/activity-consumer-context.xml        |   17 +
 .../META-INF/spring/activity-consumer-osgi.xml  |   17 +
 .../activity-registration/osgi.bnd              |    4 +
 .../activity-registration/pom.xml               |    6 +-
 .../impl/ActivityPublisherRegistrationImpl.java |   18 +
 ...tivityStreamsSubscriberRegistrationImpl.java |   18 +
 .../activity-registration-context-osgi.xml      |   17 +
 .../spring/activity-registration-context.xml    |   17 +
 .../activity-subscriber/osgi.bnd                |    4 +
 .../activity-subscriber/pom.xml                 |    6 +-
 .../spring/activity-subscriber-context.xml      |   17 +
 .../spring/activity-subscriber-osgi.xml         |   17 +
 streams-osgi-components/pom.xml                 |    7 +-
 .../streams-components-all/pom.xml              |   86 -
 streams-pojo-extensions/README.md               |    4 +
 streams-pojo-extensions/pom.xml                 |    7 +-
 streams-pojo/README.md                          |    4 +
 streams-pojo/metadata/Serializer.mup            |  699 +++---
 streams-pojo/pom.xml                            |   26 +-
 .../apache/streams/data/ActivityConverter.java  |   87 +
 .../apache/streams/data/ActivitySerializer.java |    4 +-
 .../apache/streams/data/DocumentClassifier.java |   39 +
 .../apache/streams/data/util/ActivityUtil.java  |    7 +
 .../exceptions/ActivityConversionException.java |   42 +
 .../jackson/StreamsDateTimeDeserializer.java    |   10 +-
 .../streams/jackson/StreamsDateTimeFormat.java  |   30 +
 .../jackson/StreamsDateTimeSerializer.java      |    5 +-
 .../streams/jackson/StreamsJacksonMapper.java   |   20 +-
 .../streams/jackson/StreamsJacksonModule.java   |   35 +-
 .../org/apache/streams/pojo/json/activity.json  |  191 +-
 .../apache/streams/pojo/json/collection.json    |   75 +-
 .../apache/streams/pojo/json/media_link.json    |   56 +-
 .../org/apache/streams/pojo/json/object.json    |  169 +-
 .../streams/pojo/json/objectTypes/article.json  |   24 +-
 .../streams/pojo/json/objectTypes/audio.json    |   24 +-
 .../streams/pojo/json/objectTypes/bookmark.json |   24 +-
 .../streams/pojo/json/objectTypes/comment.json  |   24 +-
 .../streams/pojo/json/objectTypes/event.json    |   32 +-
 .../streams/pojo/json/objectTypes/file.json     |   24 +-
 .../streams/pojo/json/objectTypes/folder.json   |   24 +-
 .../streams/pojo/json/objectTypes/group.json    |   24 +-
 .../streams/pojo/json/objectTypes/list.json     |   38 +-
 .../streams/pojo/json/objectTypes/note.json     |   24 +-
 .../streams/pojo/json/objectTypes/person.json   |   32 +-
 .../pojo/json/objectTypes/photo-album.json      |   24 +-
 .../streams/pojo/json/objectTypes/photo.json    |   30 +-
 .../streams/pojo/json/objectTypes/place.json    |   31 +-
 .../streams/pojo/json/objectTypes/playlist.json |   26 +-
 .../streams/pojo/json/objectTypes/product.json  |   26 +-
 .../streams/pojo/json/objectTypes/property.json |   76 +-
 .../streams/pojo/json/objectTypes/review.json   |   26 +-
 .../streams/pojo/json/objectTypes/service.json  |   26 +-
 .../streams/pojo/json/objectTypes/song.json     |   26 +-
 .../streams/pojo/json/objectTypes/status.json   |   26 +-
 .../streams/pojo/json/objectTypes/video.json    |   26 +-
 .../streams/pojo/json/verbs/favorite.json       |   32 +-
 .../apache/streams/pojo/json/verbs/follow.json  |   32 +-
 .../apache/streams/pojo/json/verbs/join.json    |   32 +-
 .../apache/streams/pojo/json/verbs/like.json    |   32 +-
 .../streams/pojo/json/verbs/make-friend.json    |   32 +-
 .../apache/streams/pojo/json/verbs/play.json    |   32 +-
 .../apache/streams/pojo/json/verbs/post.json    |   32 +-
 .../streams/pojo/json/verbs/rsvp-maybe.json     |   32 +-
 .../apache/streams/pojo/json/verbs/rsvp-no.json |   32 +-
 .../streams/pojo/json/verbs/rsvp-yes.json       |   32 +-
 .../apache/streams/pojo/json/verbs/save.json    |   32 +-
 .../apache/streams/pojo/json/verbs/share.json   |   32 +-
 .../org/apache/streams/pojo/json/verbs/tag.json |   32 +-
 .../apache/streams/pojo/json/verbs/update.json  |   52 +-
 .../data/data/util/CustomDateTimeFormat.java    |   32 +
 .../data/util/CustomDateTimeFormatTest.java     |   79 +
 .../data/data/util/DateTimeSerDeTest.java       |    3 +-
 .../streams/data/data/util/JsonUtilTest.java    |   31 -
 .../data/data/util/RFC3339UtilsTest.java        |    5 +-
 streams-runtimes/README.md                      |    7 +
 streams-runtimes/pom.xml                        |    9 +-
 streams-runtimes/streams-runtime-local/pom.xml  |   11 +-
 .../local/builders/LocalStreamBuilder.java      |   55 +-
 .../streams/local/builders/StreamComponent.java |   13 +
 ...amOnUnhandleThrowableThreadPoolExecutor.java |    1 +
 .../local/tasks/StreamsPersistWriterTask.java   |    3 +
 .../local/tasks/StreamsProcessorTask.java       |    3 +
 .../jsonschema/LocalRuntimeConfiguration.json   |    5 +-
 ...nhandledThrowableThreadPoolExecutorTest.java |   18 +
 streams-runtimes/streams-runtime-pig/pom.xml    |   18 +-
 streams-runtimes/streams-runtime-storm/pom.xml  |   16 +-
 streams-runtimes/streams-runtime-webapp/pom.xml |   10 +-
 streams-util/README.md                          |    4 +
 streams-util/pom.xml                            |   10 +-
 .../backoff/AbstractBackOffStrategy.java        |    1 +
 .../api/requests/backoff/BackOffException.java  |    1 +
 .../api/requests/backoff/BackOffStrategy.java   |    1 +
 .../impl/ConstantTimeBackOffStrategy.java       |    1 +
 .../impl/ExponentialBackOffStrategy.java        |    1 +
 .../backoff/impl/LinearTimeBackOffStrategy.java |    1 +
 .../requests/backoff/BackOffStrategyTest.java   |   18 +
 .../ConstantTimeBackOffStrategyTest.java        |   18 +
 .../backoff/ExponentialBackOffStrategyTest.java |   18 +
 .../backoff/LinearTimeBackOffStartegyTest.java  |   18 +
 .../streams/util/files/StreamsScannerUtil.java  |   18 +
 .../tokenmanager/TestBasicTokenManager.java     |   19 +-
 streams-web/pom.xml                             |  210 --
 .../main/webapp/WEB-INF/cassandra.properties    |    5 -
 .../main/webapp/WEB-INF/propertiesLoader.xml    |   36 -
 .../main/webapp/WEB-INF/spring-web-servlet.xml  |   49 -
 .../src/main/webapp/WEB-INF/streams.properties  |   43 -
 streams-web/src/main/webapp/WEB-INF/web.xml     |   57 -
 .../src/main/webapp/demo/activityDemo.html      |   26 -
 .../src/main/webapp/demo/css/activityStyles.css |    9 -
 .../src/main/webapp/demo/js/activityDemo.js     |   66 -
 .../src/main/webapp/demo/js/handlebars.js       | 2278 ------------------
 .../src/main/webapp/demo/js/publisher.js        |   43 -
 .../src/main/webapp/demo/js/subscriber.js       |   40 -
 streams-web/src/main/webapp/demo/publisher.html |   74 -
 .../src/main/webapp/demo/subscriber.html        |   40 -
 streams-web/src/main/webapp/index.html          |   10 -
 341 files changed, 8611 insertions(+), 6771 deletions(-)
----------------------------------------------------------------------



Mime
View raw message