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 2018/03/23 17:10:08 UTC
[5/5] storm git commit: Merge branch 'gitattributes' of
https://github.com/krichter722/storm into fix-eol-to-auto
Merge branch 'gitattributes' of https://github.com/krichter722/storm into fix-eol-to-auto
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/adf4efb7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/adf4efb7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/adf4efb7
Branch: refs/heads/master
Commit: adf4efb715b33abe7107175dc893a9036232a166
Parents: 0fdad2c e9c427c
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Fri Mar 23 18:08:23 2018 +0100
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Fri Mar 23 18:08:23 2018 +0100
----------------------------------------------------------------------
.gitattributes | 11 +-
docs/storm-eventhubs.md | 80 +--
external/storm-eventhubs/README.md | 90 +--
.../eventhubs/bolt/DefaultEventDataFormat.java | 94 +--
.../storm/eventhubs/bolt/EventHubBolt.java | 292 ++++-----
.../eventhubs/bolt/EventHubBoltConfig.java | 222 +++----
.../storm/eventhubs/bolt/IEventDataFormat.java | 56 +-
.../storm/eventhubs/spout/EventDataScheme.java | 156 ++---
.../storm/eventhubs/spout/FieldConstants.java | 56 +-
.../storm/eventhubs/spout/IEventDataScheme.java | 88 +--
.../spout/IEventHubReceiverFactory.java | 60 +-
.../eventhubs/spout/IPartitionCoordinator.java | 54 +-
.../eventhubs/spout/IPartitionManager.java | 74 +--
.../storm/eventhubs/spout/IStateStore.java | 62 +-
.../apache/storm/eventhubs/spout/MessageId.java | 112 ++--
.../eventhubs/spout/ZookeeperStateStore.java | 190 +++---
.../storm/eventhubs/trident/Coordinator.java | 120 ++--
.../trident/ITridentPartitionManager.java | 70 +-
.../ITridentPartitionManagerFactory.java | 52 +-
.../trident/OpaqueTridentEventHubEmitter.java | 136 ++--
.../trident/OpaqueTridentEventHubSpout.java | 128 ++--
.../storm/eventhubs/trident/Partition.java | 78 +--
.../storm/eventhubs/trident/Partitions.java | 82 +--
.../TransactionalTridentEventHubSpout.java | 132 ++--
.../storm/eventhubs/samples/EventHubLoop.java | 104 +--
.../samples/OpaqueTridentEventCount.java | 106 +--
.../samples/TransactionalTridentEventCount.java | 162 ++---
.../eventhubs/samples/bolt/GlobalCountBolt.java | 176 ++---
.../samples/bolt/PartialCountBolt.java | 136 ++--
.../spout/SpoutOutputCollectorMock.java | 142 ++--
.../storm/eventhubs/spout/StateStoreMock.java | 108 +--
.../storm/eventhubs/spout/TestEventData.java | 94 +--
.../eventhubs/trident/TridentCollectorMock.java | 114 ++--
external/storm-mongodb/README.md | 650 +++++++++----------
.../storm/mongodb/bolt/AbstractMongoBolt.java | 124 ++--
.../storm/mongodb/bolt/MongoInsertBolt.java | 248 +++----
.../storm/mongodb/bolt/MongoUpdateBolt.java | 186 +++---
.../storm/mongodb/common/MongoDbClient.java | 218 +++----
.../mongodb/common/QueryFilterCreator.java | 94 +--
.../common/SimpleQueryFilterCreator.java | 94 +--
.../mongodb/common/mapper/MongoMapper.java | 94 +--
.../common/mapper/SimpleMongoMapper.java | 110 ++--
.../common/mapper/SimpleMongoUpdateMapper.java | 92 +--
.../storm/mongodb/trident/state/MongoState.java | 290 ++++-----
.../trident/state/MongoStateFactory.java | 86 +--
.../trident/state/MongoStateUpdater.java | 70 +-
integration-test/README.md | 118 ++--
.../storm/trident/TestTridentTopology.java | 152 ++---
48 files changed, 3136 insertions(+), 3127 deletions(-)
----------------------------------------------------------------------