You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/08/13 01:23:49 UTC

[6/6] git commit: Merge PR#38 from 'renato2099/master'

Merge PR#38 from 'renato2099/master'


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

Branch: refs/heads/master
Commit: 2977287742acf18d2da7781563dbab7d0389faeb
Parents: f0404ba 2ffe216
Author: mfranklin <mf...@apache.org>
Authored: Tue Aug 12 18:11:47 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Tue Aug 12 18:11:47 2014 -0500

----------------------------------------------------------------------
 .../configuration/CassandraConfiguration.java   | 18 +++++++++++
 .../model/CassandraActivityStreamsEntry.java    | 18 +++++++++++
 .../repository/impl/CassandraKeyspace.java      | 18 +++++++++++
 .../ElasticsearchPersistWriter.java             |  1 +
 .../serializer/DatasiftActivitySerializer.java  | 32 ++++++++++----------
 .../activityconsumer/ActivityConsumer.java      | 18 +++++++++++
 .../ActivityConsumerWarehouse.java              | 18 +++++++++++
 .../impl/ActivityConsumerWarehouseImpl.java     | 18 +++++++++++
 .../impl/PushActivityConsumer.java              | 18 +++++++++++
 .../ActivityPublisherRegistration.java          | 18 +++++++++++
 .../ActivityStreamsSubscriberRegistration.java  | 18 +++++++++++
 .../ActivityStreamsSubscriber.java              | 18 +++++++++++
 .../ActivityStreamsSubscriberWarehouse.java     | 18 +++++++++++
 .../ActivityStreamsSubscription.java            | 18 +++++++++++
 .../ActivityStreamsSubscriptionFilter.java      | 18 +++++++++++
 .../ActivityStreamsSubscriptionOutput.java      | 18 +++++++++++
 .../impl/ActivityStreamsSubscriberDelegate.java | 18 +++++++++++
 .../ActivityStreamsSubscriberWarehouseImpl.java | 18 +++++++++++
 ...yStreamsSubscriptionCassandraFilterImpl.java | 18 +++++++++++
 .../impl/ActivityStreamsSubscriptionImpl.java   | 18 +++++++++++
 ...vityStreamsSubscriptionLuceneFilterImpl.java | 18 +++++++++++
 21 files changed, 359 insertions(+), 16 deletions(-)
----------------------------------------------------------------------