You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2017/04/18 21:26:35 UTC
[2/3] storm git commit: Merge branch 'eventhub3' of
https://github.com/rban1/storm
Merge branch 'eventhub3' of https://github.com/rban1/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/940096a2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/940096a2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/940096a2
Branch: refs/heads/master
Commit: 940096a275562a25eccf5da7a6b048702b1be788
Parents: f794d72 fdb9136
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Tue Apr 18 14:02:58 2017 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Tue Apr 18 14:02:58 2017 -0700
----------------------------------------------------------------------
external/storm-eventhubs/pom.xml | 29 +---
.../storm/eventhubs/bolt/EventHubBolt.java | 82 ++++++++---
.../eventhubs/bolt/EventHubBoltConfig.java | 10 +-
.../eventhubs/spout/BinaryEventDataScheme.java | 43 +++---
.../apache/storm/eventhubs/spout/EventData.java | 48 -------
.../storm/eventhubs/spout/EventDataScheme.java | 51 +++----
.../storm/eventhubs/spout/EventDataWrap.java | 48 +++++++
.../eventhubs/spout/EventHubException.java | 41 ++++++
.../storm/eventhubs/spout/EventHubFilter.java | 46 ++++++
.../eventhubs/spout/EventHubReceiverImpl.java | 141 +++++++++++--------
.../storm/eventhubs/spout/EventHubSpout.java | 24 ++--
.../eventhubs/spout/EventHubSpoutConfig.java | 18 ++-
.../eventhubs/spout/EventHubSpoutException.java | 37 -----
.../storm/eventhubs/spout/FieldConstants.java | 1 +
.../storm/eventhubs/spout/IEventDataScheme.java | 7 +-
.../storm/eventhubs/spout/IEventFilter.java | 28 ++++
.../eventhubs/spout/IEventHubReceiver.java | 11 +-
.../eventhubs/spout/IPartitionManager.java | 2 +-
.../storm/eventhubs/spout/PartitionManager.java | 28 ++--
.../spout/SerializeDeserializeUtil.java | 34 +++++
.../eventhubs/spout/SimplePartitionManager.java | 32 ++---
.../spout/StaticPartitionCoordinator.java | 1 -
.../eventhubs/spout/StringEventDataScheme.java | 43 +++---
.../trident/ITridentPartitionManager.java | 6 +-
.../TransactionalTridentEventHubEmitter.java | 36 ++---
.../trident/TridentPartitionManager.java | 29 ++--
.../eventhubs/spout/EventHubReceiverMock.java | 36 ++---
.../spout/PartitionManagerCallerMock.java | 6 +-
.../storm/eventhubs/spout/TestEventData.java | 8 +-
.../eventhubs/spout/TestEventHubSpout.java | 7 +-
pom.xml | 2 +-
31 files changed, 531 insertions(+), 404 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/940096a2/external/storm-eventhubs/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/940096a2/pom.xml
----------------------------------------------------------------------