You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/06/03 19:36:01 UTC
[47/50] [abbrv] storm git commit: Merge branch 'ehimprove' of
github.com:shanyu/storm
Merge branch 'ehimprove' of github.com:shanyu/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6978b585
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6978b585
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6978b585
Branch: refs/heads/master
Commit: 6978b58574a4de67ef12ded945e5183d96680618
Parents: a55bbbe 9c2972a
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Jun 3 13:03:48 2015 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Jun 3 13:03:48 2015 -0400
----------------------------------------------------------------------
external/storm-eventhubs/pom.xml | 38 ++---
.../eventhubs/bolt/DefaultEventDataFormat.java | 47 +++++++
.../storm/eventhubs/bolt/EventHubBolt.java | 56 +++++---
.../eventhubs/bolt/EventHubBoltConfig.java | 109 +++++++++++++++
.../storm/eventhubs/bolt/IEventDataFormat.java | 28 ++++
.../client/ConnectionStringBuilder.java | 116 ----------------
.../storm/eventhubs/client/Constants.java | 32 -----
.../storm/eventhubs/client/EventHubClient.java | 92 ------------
.../eventhubs/client/EventHubConsumerGroup.java | 72 ----------
.../eventhubs/client/EventHubException.java | 37 -----
.../eventhubs/client/EventHubReceiver.java | 139 -------------------
.../eventhubs/client/EventHubSendClient.java | 70 ----------
.../storm/eventhubs/client/EventHubSender.java | 95 -------------
.../storm/eventhubs/client/SelectorFilter.java | 38 -----
.../eventhubs/client/SelectorFilterWriter.java | 64 ---------
.../storm/eventhubs/samples/EventCount.java | 5 +-
.../storm/eventhubs/samples/EventHubLoop.java | 9 +-
.../eventhubs/spout/EventHubReceiverFilter.java | 56 --------
.../eventhubs/spout/EventHubReceiverImpl.java | 49 ++++---
.../storm/eventhubs/spout/EventHubSpout.java | 5 +
.../eventhubs/spout/EventHubSpoutConfig.java | 126 +++++++++--------
.../eventhubs/spout/IEventHubReceiver.java | 5 +-
.../spout/IEventHubReceiverFilter.java | 35 -----
.../eventhubs/spout/SimplePartitionManager.java | 11 +-
.../spout/StaticPartitionCoordinator.java | 2 +-
.../TransactionalTridentEventHubEmitter.java | 2 +-
.../trident/TridentPartitionManager.java | 12 +-
.../src/main/resources/config.properties | 5 +-
.../eventhubs/spout/EventHubReceiverMock.java | 18 +--
.../eventhubs/spout/TestEventHubSpout.java | 4 +-
30 files changed, 376 insertions(+), 1001 deletions(-)
----------------------------------------------------------------------