streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sblack...@apache.org
Subject [13/13] git commit: ran update-file-header on entire repo - now all .java, .xml, and .properties files underneath a src folder should contain an apache v2 header.
Date Mon, 19 May 2014 19:09:42 GMT
ran update-file-header on entire repo - now all .java, .xml, and .properties files underneath a src folder should contain an apache v2 header.

individuals can override the default author and organization names at the module level.

http://mojo.codehaus.org/license-maven-plugin/update-file-header-mojo.html


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

Branch: refs/heads/STREAMS-74
Commit: 067fdb5f1ccb8792436baadde649fda515c8334f
Parents: 6792054
Author: sblackmon <sblackmon@w2odigital.com>
Authored: Mon May 19 14:05:59 2014 -0500
Committer: sblackmon <sblackmon@w2odigital.com>
Committed: Mon May 19 14:05:59 2014 -0500

----------------------------------------------------------------------
 src/license/licenses.properties                 | 19 +++++++++++++++
 .../streams/config/StreamsConfigurator.java     | 20 ++++++++++++++++
 .../main/jsonschema/StreamsConfiguration.json   | 19 +++++++++++++++
 .../org/apache/streams/s3/S3Configurator.java   | 20 ++++++++++++++++
 .../streams/s3/S3ObjectInputStreamWrapper.java  | 20 ++++++++++++++++
 .../streams/s3/S3OutputStreamWrapper.java       | 20 ++++++++++++++++
 .../org/apache/streams/s3/S3PersistReader.java  | 20 ++++++++++++++++
 .../apache/streams/s3/S3PersistReaderTask.java  | 20 ++++++++++++++++
 .../org/apache/streams/s3/S3PersistWriter.java  | 20 ++++++++++++++++
 .../org/apache/streams/s3/S3Configuration.json  | 19 +++++++++++++++
 .../streams/s3/S3ReaderConfiguration.json       | 19 +++++++++++++++
 .../streams/s3/S3WriterConfiguration.json       | 19 +++++++++++++++
 .../configuration/CassandraConfiguration.java   | 20 ++++++++++++++++
 .../model/CassandraActivityStreamsEntry.java    | 20 ++++++++++++++++
 .../CassandraActivityStreamsRepository.java     | 20 ++++++++++++++++
 .../repository/impl/CassandraKeyspace.java      | 20 ++++++++++++++++
 .../impl/CassandraSubscriptionRepository.java   | 20 ++++++++++++++++
 .../spring/streams-cassandra-context.xml        | 19 +++++++++++++++
 .../CassandraActivityStreamsRepositoryTest.java | 20 ++++++++++++++++
 .../impl/CassandraActivitySubscriptionTest.java | 20 ++++++++++++++++
 .../streams/console/ConsolePersistReader.java   | 20 ++++++++++++++++
 .../streams/console/ConsolePersistWriter.java   | 20 ++++++++++++++++
 .../console/ConsolePersistWriterTask.java       | 20 ++++++++++++++++
 .../elasticsearch/ElasticsearchClient.java      | 20 ++++++++++++++++
 .../ElasticsearchClientManager.java             | 20 ++++++++++++++++
 .../ElasticsearchConfigurator.java              | 20 ++++++++++++++++
 .../ElasticsearchPersistReader.java             | 20 ++++++++++++++++
 .../ElasticsearchPersistUpdater.java            | 20 ++++++++++++++++
 .../ElasticsearchPersistWriter.java             | 20 ++++++++++++++++
 .../ElasticsearchPersistWriterTask.java         | 20 ++++++++++++++++
 .../elasticsearch/ElasticsearchQuery.java       | 20 ++++++++++++++++
 .../elasticsearch/PercolateProcessor.java       | 20 ++++++++++++++++
 .../ElasticsearchConfiguration.json             | 19 +++++++++++++++
 .../ElasticsearchReaderConfiguration.json       | 19 +++++++++++++++
 .../ElasticsearchWriterConfiguration.json       | 19 +++++++++++++++
 .../apache/streams/hbase/HbaseConfigurator.java | 20 ++++++++++++++++
 .../streams/hbase/HbasePersistWriter.java       | 20 ++++++++++++++++
 .../streams/hbase/HbasePersistWriterTask.java   | 20 ++++++++++++++++
 .../streams/hbase/HbaseConfiguration.json       | 19 +++++++++++++++
 .../src/main/resources/reference.properties     | 19 +++++++++++++++
 .../apache/streams/hdfs/HdfsConfigurator.java   | 20 ++++++++++++++++
 .../streams/hdfs/WebHdfsPersistReader.java      | 20 ++++++++++++++++
 .../streams/hdfs/WebHdfsPersistReaderTask.java  | 20 ++++++++++++++++
 .../streams/hdfs/WebHdfsPersistWriter.java      | 20 ++++++++++++++++
 .../streams/hdfs/WebHdfsPersistWriterTask.java  | 20 ++++++++++++++++
 .../apache/streams/hdfs/HdfsConfiguration.json  | 19 +++++++++++++++
 .../streams/hdfs/HdfsReaderConfiguration.json   | 19 +++++++++++++++
 .../streams/hdfs/HdfsWriterConfiguration.json   | 19 +++++++++++++++
 .../apache/streams/kafka/KafkaConfigurator.java | 20 ++++++++++++++++
 .../streams/kafka/KafkaPersistReader.java       | 20 ++++++++++++++++
 .../streams/kafka/KafkaPersistReaderTask.java   | 20 ++++++++++++++++
 .../streams/kafka/KafkaPersistWriter.java       | 20 ++++++++++++++++
 .../streams/kafka/KafkaPersistWriterTask.java   | 20 ++++++++++++++++
 .../streams/kafka/StreamsPartitioner.java       | 20 ++++++++++++++++
 .../streams/kafka/KafkaConfiguration.json       | 19 +++++++++++++++
 .../src/main/resources/reference.properties     | 19 +++++++++++++++
 .../apache/streams/mongo/MongoConfigurator.java | 20 ++++++++++++++++
 .../streams/mongo/MongoPersistWriter.java       | 20 ++++++++++++++++
 .../streams/mongo/MongoConfiguration.json       | 19 +++++++++++++++
 .../src/main/resources/reference.properties     | 19 +++++++++++++++
 .../regex/AbstractRegexExtensionExtractor.java  | 20 ++++++++++++++++
 .../streams/regex/RegexHashtagExtractor.java    | 20 ++++++++++++++++
 .../streams/regex/RegexMentionsExtractor.java   | 20 ++++++++++++++++
 .../apache/streams/regex/RegexUrlExtractor.java | 20 ++++++++++++++++
 .../org/apache/streams/regex/RegexUtils.java    | 20 ++++++++++++++++
 .../regex/RegexHashtagExtractorTest.java        | 20 ++++++++++++++++
 .../regex/RegexMentionExtractorTest.java        | 20 ++++++++++++++++
 .../streams/regex/RegexUrlExtractorTest.java    | 20 ++++++++++++++++
 .../apache/streams/regex/RegexUtilsTest.java    | 20 ++++++++++++++++
 .../org/apache/streams/urls/LinkResolver.java   | 20 ++++++++++++++++
 .../urls/LinkResolverHelperFunctions.java       | 20 ++++++++++++++++
 .../streams/urls/LinkResolverProcessor.java     | 20 ++++++++++++++++
 .../org/apache/streams/urls/LinkDetails.json    | 19 +++++++++++++++
 .../streams/urls/LinkHelperFunctionsTest.java   | 20 ++++++++++++++++
 .../streams/urls/TestLinkUnwinderProcessor.java | 20 ++++++++++++++++
 .../provider/DatasiftEventProcessor.java        | 20 ++++++++++++++++
 .../provider/DatasiftStreamConfigurator.java    | 20 ++++++++++++++++
 .../provider/DatasiftStreamProvider.java        | 20 ++++++++++++++++
 .../serializer/DatasiftActivitySerializer.java  | 20 ++++++++++++++++
 .../main/jsonschema/com/datasift/Datasift.json  | 19 +++++++++++++++
 .../com/datasift/DatasiftConfiguration.json     | 19 +++++++++++++++
 .../com/datasift/test/DatasiftSerDeTest.java    | 20 ++++++++++++++++
 .../src/test/resources/part-r-00000.json        | 23 +++++++++++++++++-
 .../part-r-00000.json_1400524903809562000       |  0
 .../part-r-00000.json_1400524918736658000       |  0
 .../api/FacebookPostActivitySerializer.java     | 20 ++++++++++++++++
 ...FacebookPublicFeedXmlActivitySerializer.java | 20 ++++++++++++++++
 .../jsonschema/com/facebook/graph/Post.json     | 19 +++++++++++++++
 .../FacebookPostActivitySerializerTest.java     | 20 ++++++++++++++++
 .../facebook/test/FacebookPostSerDeTest.java    | 20 ++++++++++++++++
 .../org/apache/streams/data/Facebook.json       | 19 +++++++++++++++
 .../src/test/resources/testpost.json            | 25 +++++++++++++++++---
 .../test/FacebookEDCAsActivityTest.java         | 20 ++++++++++++++++
 .../facebook/test/FacebookEDCSerDeTest.java     | 20 ++++++++++++++++
 .../src/test/resources/FacebookEDC.xml          | 19 +++++++++++++++
 .../flickr/test/FlickrEDCAsActivityTest.java    | 20 ++++++++++++++++
 .../gnip/flickr/test/FlickrEDCSerDeTest.java    | 20 ++++++++++++++++
 .../src/test/resources/FlickrEDC.xml            | 19 +++++++++++++++
 .../com/gplus/api/GPlusActivitySerializer.java  | 20 ++++++++++++++++
 .../com/gplus/api/GPlusEDCAsActivityTest.java   | 20 ++++++++++++++++
 .../src/test/resources/GPlusEDCFixed.json       | 23 +++++++++++++++++-
 .../jsonschema/com/instagram/Instagram.json     | 19 +++++++++++++++
 .../com/instagram/test/InstagramSerDeTest.java  | 20 ++++++++++++++++
 .../reddit/api/RedditActivitySerializer.java    | 20 ++++++++++++++++
 .../reddit/api/RedditEDCAsActivityJSONTest.java | 20 ++++++++++++++++
 .../src/test/resources/RedditEDC.json           | 23 +++++++++++++++++-
 .../src/test/resources/RedditEDC.xml            | 19 +++++++++++++++
 .../src/test/resources/RedditEDCFixed.json      | 23 +++++++++++++++++-
 .../src/test/resources/RedditEDCFlattened.xml   | 19 +++++++++++++++
 .../src/test/resources/redditTest.xml           | 19 +++++++++++++++
 .../java/com/gnip/test/YouTubeEDCSerDeTest.java | 20 ++++++++++++++++
 .../com/gnip/test/YoutubeEDCAsActivityTest.java | 20 ++++++++++++++++
 .../src/test/resources/YoutubeEDC.xml           | 19 +++++++++++++++
 .../ActivityXMLActivitySerializer.java          | 20 ++++++++++++++++
 .../gnip/powertrack/GnipActivityFixer.java      | 20 ++++++++++++++++
 .../PowerTrackActivitySerializer.java           | 20 ++++++++++++++++
 .../src/main/jsonschema/com/gnip/Gnip.json      | 19 +++++++++++++++
 .../test/PowerTrackDeserializationTest.java     | 20 ++++++++++++++++
 .../com/google/gmail/GMailConfigurator.java     | 20 ++++++++++++++++
 .../gmail/provider/GMailImapProviderTask.java   | 20 ++++++++++++++++
 .../GMailMessageActivitySerializer.java         | 20 ++++++++++++++++
 .../google/gmail/provider/GMailProvider.java    | 20 ++++++++++++++++
 .../gmail/provider/GMailRssProviderTask.java    | 20 ++++++++++++++++
 .../com/google/gmail/GMailConfiguration.json    | 19 +++++++++++++++
 .../gplus/provider/GPlusActivitySerializer.java | 20 ++++++++++++++++
 .../gplus/provider/GPlusConfigurator.java       | 20 ++++++++++++++++
 .../gplus/provider/GPlusEventProcessor.java     | 20 ++++++++++++++++
 .../provider/GPlusHistoryProviderTask.java      | 20 ++++++++++++++++
 .../google/gplus/provider/GPlusProvider.java    | 20 ++++++++++++++++
 .../com/google/gplus/GPlusConfiguration.json    | 19 +++++++++++++++
 .../gmail/test/GMailMessageSerDeTest.java       | 20 ++++++++++++++++
 .../data/MoreoverJsonActivitySerializer.java    | 20 ++++++++++++++++
 .../data/MoreoverXmlActivitySerializer.java     | 20 ++++++++++++++++
 .../streams/data/moreover/MoreoverClient.java   | 20 ++++++++++++++++
 .../data/moreover/MoreoverConfigurator.java     | 20 ++++++++++++++++
 .../streams/data/moreover/MoreoverProvider.java | 20 ++++++++++++++++
 .../data/moreover/MoreoverProviderTask.java     | 20 ++++++++++++++++
 .../streams/data/moreover/MoreoverResult.java   | 20 ++++++++++++++++
 .../data/moreover/MoreoverResultSetWrapper.java | 20 ++++++++++++++++
 .../apache/streams/data/util/MoreoverUtils.java | 20 ++++++++++++++++
 .../main/jsonschema/com/moreover/Moreover.json  | 19 +++++++++++++++
 .../com/moreover/MoreoverConfiguration.json     | 19 +++++++++++++++
 .../MoreoverJsonActivitySerializerTest.java     | 20 ++++++++++++++++
 .../data/MoreoverXmlActivitySerializerTest.java | 20 ++++++++++++++++
 .../streams/data/util/MoreoverTestUtil.java     | 20 ++++++++++++++++
 .../org/apache/streams/data/moreover.json       | 23 +++++++++++++++++-
 .../org/apache/streams/data/moreover.xml        | 20 ++++++++++++++++
 .../rss/provider/RssEventClassifier.java        | 20 ++++++++++++++++
 .../streams/rss/provider/RssEventProcessor.java | 20 ++++++++++++++++
 .../rss/provider/RssStreamConfigurator.java     | 20 ++++++++++++++++
 .../streams/rss/provider/RssStreamProvider.java | 20 ++++++++++++++++
 .../rss/provider/RssStreamProviderTask.java     | 20 ++++++++++++++++
 .../serializer/SyndEntryActivitySerializer.java | 20 ++++++++++++++++
 .../main/jsonschema/RssStreamConfiguration.json | 19 +++++++++++++++
 .../streams/rss/test/Top100FeedsTest.java       | 20 ++++++++++++++++
 .../streams/sysomos/SysomosException.java       | 20 ++++++++++++++++
 .../SysomosBeatActivityConverter.java           | 20 ++++++++++++++++
 .../streams/sysomos/data/HeartbeatInfo.java     | 20 ++++++++++++++++
 .../sysomos/data/SysomosTagDefinition.java      | 20 ++++++++++++++++
 .../sysomos/proessor/SysomosTypeConverter.java  | 20 ++++++++++++++++
 .../provider/AbstractRequestBuilder.java        | 20 ++++++++++++++++
 .../sysomos/provider/ContentRequestBuilder.java | 20 ++++++++++++++++
 .../sysomos/provider/RequestBuilder.java        | 20 ++++++++++++++++
 .../streams/sysomos/provider/SysomosClient.java | 20 ++++++++++++++++
 .../provider/SysomosHeartbeatStream.java        | 20 ++++++++++++++++
 .../sysomos/provider/SysomosProvider.java       | 20 ++++++++++++++++
 .../streams/sysomos/util/SysomosUtils.java      | 20 ++++++++++++++++
 .../main/jsonschema/com/sysomos/Sysomos.json    | 19 +++++++++++++++
 .../com/sysomos/SysomosConfiguration.json       | 19 +++++++++++++++
 .../com/sysomos/test/SysomosJsonSerDeTest.java  | 20 ++++++++++++++++
 .../com/sysomos/test/SysomosXmlSerDeTest.java   | 20 ++++++++++++++++
 .../processor/TwitterEventProcessor.java        | 20 ++++++++++++++++
 .../processor/TwitterProfileProcessor.java      | 20 ++++++++++++++++
 .../twitter/processor/TwitterTypeConverter.java | 20 ++++++++++++++++
 .../twitter/provider/TwitterErrorHandler.java   | 20 ++++++++++++++++
 .../provider/TwitterEventClassifier.java        | 20 ++++++++++++++++
 .../provider/TwitterStreamConfigurator.java     | 20 ++++++++++++++++
 .../twitter/provider/TwitterStreamProvider.java | 20 ++++++++++++++++
 .../provider/TwitterStreamProviderTask.java     | 20 ++++++++++++++++
 .../provider/TwitterTimelineProvider.java       | 20 ++++++++++++++++
 .../provider/TwitterTimelineProviderTask.java   | 20 ++++++++++++++++
 .../TwitterUserInformationProvider.java         | 20 ++++++++++++++++
 .../serializer/StreamsTwitterMapper.java        | 20 ++++++++++++++++
 .../TwitterJsonActivitySerializer.java          | 20 ++++++++++++++++
 .../TwitterJsonDeleteActivitySerializer.java    | 20 ++++++++++++++++
 .../TwitterJsonRetweetActivitySerializer.java   | 20 ++++++++++++++++
 .../TwitterJsonTweetActivitySerializer.java     | 20 ++++++++++++++++
 ...erJsonUserstreameventActivitySerializer.java | 20 ++++++++++++++++
 .../src/main/jsonschema/com/twitter/Delete.json | 19 +++++++++++++++
 .../main/jsonschema/com/twitter/FriendList.json | 19 +++++++++++++++
 .../main/jsonschema/com/twitter/Retweet.json    | 19 +++++++++++++++
 .../com/twitter/TwitterConfiguration.json       | 19 +++++++++++++++
 .../com/twitter/TwitterStreamConfiguration.json | 19 +++++++++++++++
 .../TwitterUserInformationConfiguration.json    | 19 +++++++++++++++
 .../jsonschema/com/twitter/UserstreamEvent.json | 19 +++++++++++++++
 .../src/main/jsonschema/com/twitter/tweet.json  | 19 +++++++++++++++
 .../streams/twitter/test/SimpleTweetTest.java   | 20 ++++++++++++++++
 .../twitter/test/TweetActivitySerDeTest.java    | 20 ++++++++++++++++
 .../streams/twitter/test/TweetSerDeTest.java    | 20 ++++++++++++++++
 .../test/TwitterEventClassifierTest.java        | 20 ++++++++++++++++
 .../twitter/test/TwitterStreamProviderTest.java | 20 ++++++++++++++++
 .../org/apache/streams/core/DatumStatus.java    | 20 ++++++++++++++++
 .../streams/core/DatumStatusCountable.java      | 20 ++++++++++++++++
 .../apache/streams/core/DatumStatusCounter.java | 20 ++++++++++++++++
 .../org/apache/streams/core/StreamBuilder.java  | 20 ++++++++++++++++
 .../org/apache/streams/core/StreamHandler.java  | 20 ++++++++++++++++
 .../org/apache/streams/core/StreamState.java    | 20 ++++++++++++++++
 .../org/apache/streams/core/StreamsDatum.java   | 20 ++++++++++++++++
 .../org/apache/streams/core/StreamsFilter.java  | 20 ++++++++++++++++
 .../apache/streams/core/StreamsOperation.java   | 20 ++++++++++++++++
 .../streams/core/StreamsPersistReader.java      | 20 ++++++++++++++++
 .../streams/core/StreamsPersistWriter.java      | 20 ++++++++++++++++
 .../apache/streams/core/StreamsProcessor.java   | 20 ++++++++++++++++
 .../apache/streams/core/StreamsProvider.java    | 20 ++++++++++++++++
 .../apache/streams/core/StreamsResultSet.java   | 20 ++++++++++++++++
 .../activityconsumer/ActivityConsumer.java      | 20 ++++++++++++++++
 .../ActivityConsumerWarehouse.java              | 20 ++++++++++++++++
 .../impl/ActivityConsumerWarehouseImpl.java     | 20 ++++++++++++++++
 .../impl/PushActivityConsumer.java              | 20 ++++++++++++++++
 .../spring/activity-consumer-context.xml        | 20 ++++++++++++++++
 .../META-INF/spring/activity-consumer-osgi.xml  | 20 ++++++++++++++++
 .../ActivityPublisherRegistration.java          | 20 ++++++++++++++++
 .../ActivityStreamsSubscriberRegistration.java  | 20 ++++++++++++++++
 .../impl/ActivityPublisherRegistrationImpl.java | 20 ++++++++++++++++
 ...tivityStreamsSubscriberRegistrationImpl.java | 20 ++++++++++++++++
 .../activity-registration-context-osgi.xml      | 20 ++++++++++++++++
 .../spring/activity-registration-context.xml    | 20 ++++++++++++++++
 .../ActivityStreamsSubscriber.java              | 20 ++++++++++++++++
 .../ActivityStreamsSubscriberWarehouse.java     | 20 ++++++++++++++++
 .../ActivityStreamsSubscription.java            | 20 ++++++++++++++++
 .../ActivityStreamsSubscriptionFilter.java      | 20 ++++++++++++++++
 .../ActivityStreamsSubscriptionOutput.java      | 20 ++++++++++++++++
 .../impl/ActivityStreamsSubscriberDelegate.java | 20 ++++++++++++++++
 .../ActivityStreamsSubscriberWarehouseImpl.java | 20 ++++++++++++++++
 ...yStreamsSubscriptionCassandraFilterImpl.java | 20 ++++++++++++++++
 .../impl/ActivityStreamsSubscriptionImpl.java   | 20 ++++++++++++++++
 ...vityStreamsSubscriptionLuceneFilterImpl.java | 20 ++++++++++++++++
 .../spring/activity-subscriber-context.xml      | 20 ++++++++++++++++
 .../spring/activity-subscriber-osgi.xml         | 20 ++++++++++++++++
 .../apache/streams/data/ActivitySerializer.java | 20 ++++++++++++++++
 .../apache/streams/data/util/ActivityUtil.java  | 20 ++++++++++++++++
 .../org/apache/streams/data/util/JsonUtil.java  | 20 ++++++++++++++++
 .../apache/streams/data/util/RFC3339Utils.java  | 20 ++++++++++++++++
 .../ActivityDeserializerException.java          | 20 ++++++++++++++++
 .../exceptions/ActivitySerializerException.java | 20 ++++++++++++++++
 .../jackson/StreamsDateTimeDeserializer.java    | 20 ++++++++++++++++
 .../jackson/StreamsDateTimeSerializer.java      | 20 ++++++++++++++++
 .../streams/jackson/StreamsJacksonMapper.java   | 20 ++++++++++++++++
 .../streams/jackson/StreamsJacksonModule.java   | 20 ++++++++++++++++
 .../jackson/StreamsPeriodDeserializer.java      | 20 ++++++++++++++++
 .../jackson/StreamsPeriodSerializer.java        | 20 ++++++++++++++++
 .../org/apache/streams/pojo/json/activity.json  | 19 +++++++++++++++
 .../apache/streams/pojo/json/collection.json    | 19 +++++++++++++++
 .../apache/streams/pojo/json/media_link.json    | 19 +++++++++++++++
 .../org/apache/streams/pojo/json/object.json    | 19 +++++++++++++++
 .../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    | 19 +++++++++++++++
 .../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     | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/note.json     | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/person.json   | 19 +++++++++++++++
 .../pojo/json/objectTypes/photo-album.json      | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/photo.json    | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/place.json    | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/playlist.json | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/product.json  | 19 +++++++++++++++
 .../streams/pojo/json/objectTypes/property.json | 19 +++++++++++++++
 .../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       | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/follow.json  | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/join.json    | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/like.json    | 19 +++++++++++++++
 .../streams/pojo/json/verbs/make-friend.json    | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/play.json    | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/post.json    | 19 +++++++++++++++
 .../streams/pojo/json/verbs/rsvp-maybe.json     | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/rsvp-no.json | 19 +++++++++++++++
 .../streams/pojo/json/verbs/rsvp-yes.json       | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/save.json    | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/share.json   | 19 +++++++++++++++
 .../org/apache/streams/pojo/json/verbs/tag.json | 19 +++++++++++++++
 .../apache/streams/pojo/json/verbs/update.json  | 19 +++++++++++++++
 .../data/data/util/DateTimeSerDeTest.java       | 20 ++++++++++++++++
 .../streams/data/data/util/JsonUtilTest.java    | 20 ++++++++++++++++
 .../data/data/util/RFC3339UtilsTest.java        | 20 ++++++++++++++++
 .../local/builders/InvalidStreamException.java  | 20 ++++++++++++++++
 .../local/builders/LocalStreamBuilder.java      | 20 ++++++++++++++++
 .../streams/local/builders/StreamComponent.java | 20 ++++++++++++++++
 .../streams/local/tasks/BaseStreamsTask.java    | 20 ++++++++++++++++
 .../tasks/LocalStreamProcessMonitorThread.java  | 20 ++++++++++++++++
 .../tasks/StatusCounterMonitorRunnable.java     | 20 ++++++++++++++++
 .../local/tasks/StatusCounterMonitorThread.java | 20 ++++++++++++++++
 .../streams/local/tasks/StreamsMergeTask.java   | 20 ++++++++++++++++
 .../local/tasks/StreamsPersistWriterTask.java   | 20 ++++++++++++++++
 .../local/tasks/StreamsProcessorTask.java       | 20 ++++++++++++++++
 .../local/tasks/StreamsProviderTask.java        | 20 ++++++++++++++++
 .../apache/streams/local/tasks/StreamsTask.java | 20 ++++++++++++++++
 .../jsonschema/LocalRuntimeConfiguration.json   | 19 +++++++++++++++
 .../local/builders/LocalStreamBuilderTest.java  | 20 ++++++++++++++++
 .../local/builders/ToyLocalBuilderExample.java  | 20 ++++++++++++++++
 .../streams/local/tasks/BasicTasksTest.java     | 20 ++++++++++++++++
 .../test/processors/DoNothingProcessor.java     | 20 ++++++++++++++++
 .../PassthroughDatumCounterProcessor.java       | 20 ++++++++++++++++
 .../test/providers/NumericMessageProvider.java  | 20 ++++++++++++++++
 .../local/test/writer/DatumCounterWriter.java   | 20 ++++++++++++++++
 .../local/test/writer/DoNothingWriter.java      | 20 ++++++++++++++++
 .../local/test/writer/SystemOutWriter.java      | 20 ++++++++++++++++
 .../component/ExpectedDatumsPersistWriter.java  | 20 ++++++++++++++++
 .../test/component/FileReaderProvider.java      | 20 ++++++++++++++++
 .../test/component/StreamsDatumConverter.java   | 20 ++++++++++++++++
 .../component/StringToDocumentConverter.java    | 20 ++++++++++++++++
 .../tests/TestComponentsLocalStream.java        | 20 ++++++++++++++++
 .../tests/TestExpectedDatumsPersitWriter.java   | 20 ++++++++++++++++
 .../component/tests/TestFileReaderProvider.java | 20 ++++++++++++++++
 .../streams/pig/StreamsComponentFactory.java    | 20 ++++++++++++++++
 .../apache/streams/pig/StreamsPigBuilder.java   | 20 ++++++++++++++++
 .../streams/pig/StreamsProcessDatumExec.java    | 20 ++++++++++++++++
 .../streams/pig/StreamsProcessDocumentExec.java | 20 ++++++++++++++++
 .../streams/pig/StreamsSerializerExec.java      | 20 ++++++++++++++++
 .../org/apache/streams/pig/StreamsStorage.java  | 20 ++++++++++++++++
 .../src/test/java/PigProcessorTest.java         | 19 +++++++++++++++
 .../src/test/java/PigSerializerTest.java        | 19 +++++++++++++++
 .../trident/StreamsPersistWriterState.java      | 20 ++++++++++++++++
 .../storm/trident/StreamsProcessorFunction.java | 20 ++++++++++++++++
 .../storm/trident/StreamsProviderSpout.java     | 20 ++++++++++++++++
 .../streams/storm/trident/StreamsTopology.java  | 20 ++++++++++++++++
 .../aggregation/ActivityAggregator.java         | 20 ++++++++++++++++
 .../configuration/EipConfigurator.java          | 20 ++++++++++++++++
 .../ActivityPublisherRegistrationProcessor.java | 20 ++++++++++++++++
 ...yStreamsSubscriberRegistrationProcessor.java | 20 ++++++++++++++++
 .../routers/ActivityConsumerRouteBuilder.java   | 20 ++++++++++++++++
 .../ActivityStreamsSubscriberRouteBuilder.java  | 20 ++++++++++++++++
 .../routers/impl/ActivityConsumerRouter.java    | 20 ++++++++++++++++
 .../impl/ActivityStreamsSubscriberRouter.java   | 20 ++++++++++++++++
 .../messaging/service/ActivityService.java      | 20 ++++++++++++++++
 .../messaging/service/SubscriptionService.java  | 20 ++++++++++++++++
 .../service/impl/CassandraActivityService.java  | 20 ++++++++++++++++
 .../impl/CassandraSubscriptionService.java      | 20 ++++++++++++++++
 .../META-INF/spring/propertiesLoader.xml        | 19 +++++++++++++++
 .../spring/streams-eip-applicationContext.xml   | 19 +++++++++++++++
 .../streams-eip-osgi-component-import.xml       | 20 ++++++++++++++++
 .../META-INF/spring/streamsCamelContext.xml     | 20 ++++++++++++++++
 .../main/resources/META-INF/streams.properties  | 19 +++++++++++++++
 .../impl/CassandraActivityServiceTest.java      | 20 ++++++++++++++++
 .../org/apache/streams/util/ComponentUtils.java | 20 ++++++++++++++++
 .../java/org/apache/streams/util/DateUtil.java  | 20 ++++++++++++++++
 .../java/org/apache/streams/util/GuidUtils.java | 20 ++++++++++++++++
 .../org/apache/streams/util/RegexUtils.java     | 20 ++++++++++++++++
 .../apache/streams/util/SerializationUtil.java  | 20 ++++++++++++++++
 .../main/webapp/WEB-INF/cassandra.properties    | 19 +++++++++++++++
 .../main/webapp/WEB-INF/propertiesLoader.xml    | 19 +++++++++++++++
 .../main/webapp/WEB-INF/spring-web-servlet.xml  | 19 +++++++++++++++
 .../src/main/webapp/WEB-INF/streams.properties  | 19 +++++++++++++++
 streams-web/src/main/webapp/WEB-INF/web.xml     | 19 +++++++++++++++
 .../src/main/webapp/demo/activityDemo.html      | 19 +++++++++++++++
 .../src/main/webapp/demo/css/activityStyles.css | 19 +++++++++++++++
 .../src/main/webapp/demo/js/activityDemo.js     | 19 +++++++++++++++
 .../src/main/webapp/demo/js/handlebars.js       | 20 ++++++++++++++++
 .../src/main/webapp/demo/js/publisher.js        | 19 +++++++++++++++
 .../src/main/webapp/demo/js/subscriber.js       | 19 +++++++++++++++
 streams-web/src/main/webapp/demo/publisher.html | 19 +++++++++++++++
 .../src/main/webapp/demo/subscriber.html        | 19 +++++++++++++++
 streams-web/src/main/webapp/index.html          | 19 +++++++++++++++
 372 files changed, 7307 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/src/license/licenses.properties
----------------------------------------------------------------------
diff --git a/src/license/licenses.properties b/src/license/licenses.properties
index ac8cf10..8d09dc1 100644
--- a/src/license/licenses.properties
+++ b/src/license/licenses.properties
@@ -1 +1,20 @@
+###
+# #%L
+# Apache Streams Project
+# %%
+# Copyright (C) 2013 - 2014 Apache Streams Project
+# %%
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# 
+#      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.
+# #L%
+###
 apache_v2_streams=Streams~~license:license.txt~~header:header.txt
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java
----------------------------------------------------------------------
diff --git a/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java b/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java
index e35dd5d..247902f 100644
--- a/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java
+++ b/streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java
@@ -18,6 +18,26 @@
 
 package org.apache.streams.config;
 
+/*
+ * #%L
+ * streams-config
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-config/src/main/jsonschema/StreamsConfiguration.json
----------------------------------------------------------------------
diff --git a/streams-config/src/main/jsonschema/StreamsConfiguration.json b/streams-config/src/main/jsonschema/StreamsConfiguration.json
index 9a23130..7f8500b 100644
--- a/streams-config/src/main/jsonschema/StreamsConfiguration.json
+++ b/streams-config/src/main/jsonschema/StreamsConfiguration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-config
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java
index dfa0426..9d6fbfb 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java
@@ -17,6 +17,26 @@
  */
 package org.apache.streams.s3;
 
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.typesafe.config.Config;
 import org.slf4j.Logger;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java
index c13314d..72e5275 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java
@@ -17,6 +17,26 @@
  */
 package org.apache.streams.s3;
 
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.amazonaws.services.s3.model.S3Object;
 import com.amazonaws.services.s3.model.S3ObjectInputStream;
 import org.slf4j.Logger;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3OutputStreamWrapper.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3OutputStreamWrapper.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3OutputStreamWrapper.java
index 08fc774..4f0ec69 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3OutputStreamWrapper.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3OutputStreamWrapper.java
@@ -17,6 +17,26 @@
  */
 package org.apache.streams.s3;
 
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.amazonaws.services.s3.AmazonS3Client;
 import com.amazonaws.services.s3.model.ObjectMetadata;
 import com.amazonaws.services.s3.transfer.TransferManager;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReader.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReader.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReader.java
index 5c7413e..8c4286e 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReader.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReader.java
@@ -17,6 +17,26 @@
  */
 package org.apache.streams.s3;
 
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.amazonaws.ClientConfiguration;
 import com.amazonaws.Protocol;
 import com.amazonaws.auth.AWSCredentials;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReaderTask.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReaderTask.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReaderTask.java
index 73763e6..664bead 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReaderTask.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistReaderTask.java
@@ -17,6 +17,26 @@
  */
 package org.apache.streams.s3;
 
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.google.common.base.Strings;
 import org.apache.streams.core.DatumStatus;
 import org.apache.streams.core.StreamsDatum;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
index 058f748..fc53cfb 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
@@ -17,6 +17,26 @@
  */
 package org.apache.streams.s3;
 
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.amazonaws.ClientConfiguration;
 import com.amazonaws.Protocol;
 import com.amazonaws.auth.AWSCredentials;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3Configuration.json
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3Configuration.json b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3Configuration.json
index 863668f..60fa0e6 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3Configuration.json
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3Configuration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3ReaderConfiguration.json
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3ReaderConfiguration.json b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3ReaderConfiguration.json
index 2959b3d..5fbb3b7 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3ReaderConfiguration.json
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3ReaderConfiguration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3WriterConfiguration.json
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3WriterConfiguration.json b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3WriterConfiguration.json
index f43087b..5f42393 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3WriterConfiguration.json
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/jsonschema/org/apache/streams/s3/S3WriterConfiguration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-persist-s3
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/configuration/CassandraConfiguration.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/configuration/CassandraConfiguration.java b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/configuration/CassandraConfiguration.java
index 39e74a7..f12e17e 100644
--- a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/configuration/CassandraConfiguration.java
+++ b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/configuration/CassandraConfiguration.java
@@ -1,5 +1,25 @@
 package org.apache.streams.cassandra.configuration;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/model/CassandraActivityStreamsEntry.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/model/CassandraActivityStreamsEntry.java b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/model/CassandraActivityStreamsEntry.java
index 733a132..f4c276a 100644
--- a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/model/CassandraActivityStreamsEntry.java
+++ b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/model/CassandraActivityStreamsEntry.java
@@ -1,5 +1,25 @@
 package org.apache.streams.cassandra.model;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.apache.rave.model.ActivityStreamsObject;
 import org.apache.rave.portal.model.impl.ActivityStreamsEntryImpl;
 import org.apache.rave.portal.model.impl.ActivityStreamsObjectImpl;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepository.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepository.java b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepository.java
index 56e5416..1dab117 100644
--- a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepository.java
+++ b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepository.java
@@ -18,6 +18,26 @@
 
 package org.apache.streams.cassandra.repository.impl;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.datastax.driver.core.Cluster;
 import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.Row;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraKeyspace.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraKeyspace.java b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraKeyspace.java
index 0551bf2..29fbc44 100644
--- a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraKeyspace.java
+++ b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraKeyspace.java
@@ -1,5 +1,25 @@
 package org.apache.streams.cassandra.repository.impl;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.datastax.driver.core.Cluster;
 import com.datastax.driver.core.Session;
 import com.datastax.driver.core.exceptions.AlreadyExistsException;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraSubscriptionRepository.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraSubscriptionRepository.java b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraSubscriptionRepository.java
index f5fe471..6948e06 100644
--- a/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraSubscriptionRepository.java
+++ b/streams-contrib/streams-persist-cassandra/src/main/java/org/apache/streams/cassandra/repository/impl/CassandraSubscriptionRepository.java
@@ -18,6 +18,26 @@
 
 package org.apache.streams.cassandra.repository.impl;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.exceptions.AlreadyExistsException;
 import org.apache.commons.lang.StringUtils;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/main/resources/META_INF/spring/streams-cassandra-context.xml
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/main/resources/META_INF/spring/streams-cassandra-context.xml b/streams-contrib/streams-persist-cassandra/src/main/resources/META_INF/spring/streams-cassandra-context.xml
index 842c918..c5c5035 100644
--- a/streams-contrib/streams-persist-cassandra/src/main/resources/META_INF/spring/streams-cassandra-context.xml
+++ b/streams-contrib/streams-persist-cassandra/src/main/resources/META_INF/spring/streams-cassandra-context.xml
@@ -1,4 +1,23 @@
 <!--
+  #%L
+  streams-persist-cassandra [org.apache.streams]
+  %%
+  Copyright (C) 2013 - 2014 Apache Streams Project
+  %%
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+  
+       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.
+  #L%
+  -->
+<!--
   ~ 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

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java b/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
index 978af10..202dced 100644
--- a/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
+++ b/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivityStreamsRepositoryTest.java
@@ -18,6 +18,26 @@
 
 package org.apache.streams.cassandra.repository.impl;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.datastax.driver.core.ResultSet;
 import org.apache.rave.model.ActivityStreamsEntry;
 import org.apache.rave.model.ActivityStreamsObject;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivitySubscriptionTest.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivitySubscriptionTest.java b/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivitySubscriptionTest.java
index 2a90462..81a8aa2 100644
--- a/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivitySubscriptionTest.java
+++ b/streams-contrib/streams-persist-cassandra/src/test/java/org/apache/streams/cassandra/repository/impl/CassandraActivitySubscriptionTest.java
@@ -18,6 +18,26 @@
 
 package org.apache.streams.cassandra.repository.impl;
 
+/*
+ * #%L
+ * streams-persist-cassandra [org.apache.streams]
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.apache.streams.osgi.components.activitysubscriber.ActivityStreamsSubscription;
 import org.apache.streams.osgi.components.activitysubscriber.impl.ActivityStreamsSubscriptionImpl;
 import org.junit.Before;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
index a3967e7..14a5d8b 100644
--- a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
+++ b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
@@ -1,5 +1,25 @@
 package org.apache.streams.console;
 
+/*
+ * #%L
+ * streams-persist-console
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Preconditions;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriter.java b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriter.java
index e8efc6d..8f6e0cb 100644
--- a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriter.java
+++ b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriter.java
@@ -1,5 +1,25 @@
 package org.apache.streams.console;
 
+/*
+ * #%L
+ * streams-persist-console
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Preconditions;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java
index e5009f0..be6ebc6 100644
--- a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java
+++ b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java
@@ -18,6 +18,26 @@
 
 package org.apache.streams.console;
 
+/*
+ * #%L
+ * streams-persist-console
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.apache.streams.core.StreamsDatum;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClient.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClient.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClient.java
index cc75fb0..8118611 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClient.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClient.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.elasticsearch.Version;
 import org.elasticsearch.client.Client;
 

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClientManager.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClientManager.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClientManager.java
index 2f8658a..a5cf0d1 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClientManager.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchClientManager.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.apache.commons.lang.builder.EqualsBuilder;
 import org.apache.commons.lang.builder.HashCodeBuilder;
 import org.apache.commons.lang.builder.ToStringBuilder;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchConfigurator.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchConfigurator.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchConfigurator.java
index e07e50f..31ba812 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchConfigurator.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchConfigurator.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.typesafe.config.Config;
 import org.slf4j.Logger;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java
index 54d29d2..92d15e4 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReader.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.google.common.collect.Queues;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
index 662a084..ca15bc2 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Objects;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
index 271521c..8539ed8 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Objects;
 import com.google.common.base.Optional;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriterTask.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriterTask.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriterTask.java
index 744a216..bb18076 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriterTask.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriterTask.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import org.apache.streams.core.StreamsDatum;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
index 2430c41..77e71a8 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.google.common.collect.Lists;
 import com.google.common.base.Objects;
 import com.typesafe.config.Config;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/PercolateProcessor.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/PercolateProcessor.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/PercolateProcessor.java
index c10c5d5..33c3799 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/PercolateProcessor.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/PercolateProcessor.java
@@ -1,5 +1,25 @@
 package org.apache.streams.elasticsearch;
 
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ArrayNode;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchConfiguration.json
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchConfiguration.json b/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchConfiguration.json
index 6524dcc..574df11 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchConfiguration.json
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchConfiguration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchReaderConfiguration.json
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchReaderConfiguration.json b/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchReaderConfiguration.json
index 1f1c720..69111d3 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchReaderConfiguration.json
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchReaderConfiguration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchWriterConfiguration.json
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchWriterConfiguration.json b/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchWriterConfiguration.json
index b107be6..a48ecc4 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchWriterConfiguration.json
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/jsonschema/org/apache/streams/elasticsearch/ElasticsearchWriterConfiguration.json
@@ -1,3 +1,22 @@
+/*
+ * #%L
+ * streams-persist-elasticsearch
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
 {
     "type": "object",
     "$schema": "http://json-schema.org/draft-03/schema",

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbaseConfigurator.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbaseConfigurator.java b/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbaseConfigurator.java
index 283307f..37a9d7b 100644
--- a/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbaseConfigurator.java
+++ b/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbaseConfigurator.java
@@ -1,5 +1,25 @@
 package org.apache.streams.hbase;
 
+/*
+ * #%L
+ * streams-persist-hbase
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.typesafe.config.Config;
 import org.apache.streams.config.StreamsConfigurator;
 import org.slf4j.Logger;

http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/067fdb5f/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbasePersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbasePersistWriter.java b/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbasePersistWriter.java
index 4754c0d..434862f 100644
--- a/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbasePersistWriter.java
+++ b/streams-contrib/streams-persist-hbase/src/main/java/org/apache/streams/hbase/HbasePersistWriter.java
@@ -1,5 +1,25 @@
 package org.apache.streams.hbase;
 
+/*
+ * #%L
+ * streams-persist-hbase
+ * %%
+ * Copyright (C) 2013 - 2014 Apache Streams Project
+ * %%
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      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.
+ * #L%
+ */
+
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import org.apache.hadoop.conf.Configuration;


Mime
View raw message