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 <ptgo...@gmail.com> Authored: Wed Jun 3 13:03:48 2015 -0400 Committer: P. Taylor Goetz <ptgo...@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(-) ----------------------------------------------------------------------