You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by da...@apache.org on 2018/03/21 18:11:32 UTC
[5/5] storm git commit: [STORM-2999] Add generics to static type of
method parameters and variables where applicable
[STORM-2999] Add generics to static type of method parameters and variables where applicable
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0fdad2c0
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0fdad2c0
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0fdad2c0
Branch: refs/heads/master
Commit: 0fdad2c0ff357c431454128dd937edf2876a5fb5
Parents: 8c8c0c3 1582024
Author: Derek Dagit <de...@oath.com>
Authored: Wed Mar 21 11:05:32 2018 -0500
Committer: Derek Dagit <de...@oath.com>
Committed: Wed Mar 21 11:05:32 2018 -0500
----------------------------------------------------------------------
.../storm/hbase/topology/TotalWordCounter.java | 1 -
.../storm/hbase/topology/WordCounter.java | 1 -
.../apache/storm/hbase/topology/WordSpout.java | 1 -
.../storm/hdfs/spout/HdfsSpoutTopology.java | 2 +-
.../storm/hive/trident/TridentHiveTopology.java | 2 +-
.../org/apache/storm/jdbc/spout/UserSpout.java | 1 -
.../jdbc/topology/AbstractUserTopology.java | 2 +-
.../apache/storm/jms/example/GenericBolt.java | 1 -
.../org/apache/storm/loadgen/CaptureLoad.java | 4 +--
.../loadgen/HttpForwardingMetricsServer.java | 2 +-
.../storm/loadgen/ThroughputVsLatency.java | 3 +-
.../mongodb/topology/TotalWordCounter.java | 1 -
.../storm/mongodb/topology/WordSpout.java | 1 -
.../apache/storm/perf/LowThroughputTopo.java | 7 ++--
.../storm/perf/SimplifiedWordCountTopo.java | 2 +-
.../apache/storm/perf/spout/WordGenSpout.java | 9 +++--
.../org/apache/storm/perf/utils/Helper.java | 2 +-
.../storm/redis/topology/WordCounter.java | 1 -
.../apache/storm/redis/topology/WordSpout.java | 1 -
.../storm/starter/FastWordCountTopology.java | 2 +-
.../storm/starter/InOrderDeliveryTest.java | 2 +-
.../starter/ResourceAwareExampleTopology.java | 2 +-
.../storm/starter/bolt/RollingCountAggBolt.java | 1 -
.../storm/starter/bolt/RollingCountBolt.java | 1 -
.../storm/common/AbstractHadoopAutoCreds.java | 4 +--
.../AbstractHadoopNimbusPluginAutoCreds.java | 12 +++----
.../apache/storm/hbase/security/AutoHBase.java | 2 +-
.../storm/hbase/security/AutoHBaseCommand.java | 2 +-
.../storm/hbase/security/AutoHBaseNimbus.java | 12 +++----
.../apache/storm/hdfs/security/AutoHDFS.java | 2 +-
.../storm/hdfs/security/AutoHDFSCommand.java | 2 +-
.../storm/hdfs/security/AutoHDFSNimbus.java | 15 ++++----
.../storm/hdfs/security/HdfsSecurityUtil.java | 2 +-
.../apache/storm/hive/security/AutoHive.java | 2 +-
.../storm/hive/security/AutoHiveCommand.java | 2 +-
.../storm/hive/security/AutoHiveNimbus.java | 14 ++++----
.../impl/ObjectMapperCqlStatementMapper.java | 2 +-
.../trident/state/CassandraMapStateFactory.java | 10 +++---
.../trident/state/MapStateFactoryBuilder.java | 10 +++---
.../apache/storm/cassandra/WeatherSpout.java | 2 +-
.../elasticsearch/bolt/AbstractEsBolt.java | 2 +-
.../storm/elasticsearch/bolt/EsIndexBolt.java | 2 +-
.../elasticsearch/bolt/EsPercolateBolt.java | 2 +-
.../eventhubs/spout/BinaryEventDataScheme.java | 4 +--
.../storm/eventhubs/spout/EventDataScheme.java | 4 +--
.../eventhubs/spout/EventHubReceiverImpl.java | 4 +--
.../storm/eventhubs/spout/EventHubSpout.java | 2 +-
.../eventhubs/spout/IEventHubReceiver.java | 2 +-
.../eventhubs/spout/IPartitionManager.java | 2 +-
.../eventhubs/spout/SimplePartitionManager.java | 2 +-
.../TransactionalTridentEventHubEmitter.java | 10 +++---
.../TransactionalTridentEventHubSpout.java | 4 +--
.../eventhubs/samples/bolt/GlobalCountBolt.java | 2 +-
.../eventhubs/spout/EventHubReceiverMock.java | 2 +-
.../TestTransactionalTridentEmitter.java | 6 ++--
.../org/apache/storm/hbase/bolt/HBaseBolt.java | 2 +-
.../storm/hbase/bolt/HBaseLookupBolt.java | 1 -
.../hbase/state/HBaseKeyValueStateProvider.java | 4 +--
.../hbase/trident/state/HBaseMapState.java | 2 +-
.../storm/hbase/trident/state/HBaseState.java | 4 +--
.../hbase/trident/state/HBaseStateFactory.java | 2 +-
.../apache/storm/hdfs/spout/TestHdfsSpout.java | 4 +--
.../storm/jdbc/bolt/AbstractJdbcBolt.java | 2 +-
.../apache/storm/jdbc/bolt/JdbcInsertBolt.java | 2 +-
.../storm/jdbc/trident/state/JdbcState.java | 2 +-
.../jdbc/trident/state/JdbcStateFactory.java | 2 +-
.../storm/jdbc/common/JdbcClientTest.java | 2 +-
.../storm/jms/trident/JmsStateFactory.java | 2 +-
.../storm/jms/trident/TridentJmsSpout.java | 6 ++--
.../KafkaTridentSpoutBatchMetadataTest.java | 2 +-
.../jvm/org/apache/storm/kafka/KafkaSpout.java | 2 +-
.../apache/storm/kafka/PartitionManager.java | 2 +-
.../src/jvm/org/apache/storm/kafka/ZkState.java | 7 ++--
.../kafka/trident/OpaqueTridentKafkaSpout.java | 15 ++++++--
.../kafka/trident/TridentKafkaEmitter.java | 37 ++++++++++++--------
.../apache/storm/kafka/ZkCoordinatorTest.java | 4 +--
.../mongodb/trident/state/MongoMapState.java | 4 +--
.../storm/mongodb/trident/state/MongoState.java | 4 +--
.../storm/redis/bolt/AbstractRedisBolt.java | 2 +-
.../trident/state/RedisClusterMapState.java | 2 +-
.../redis/trident/state/RedisClusterState.java | 2 +-
.../redis/trident/state/RedisMapState.java | 2 +-
.../storm/redis/trident/state/RedisState.java | 2 +-
.../rocketmq/trident/state/RocketMqState.java | 2 +-
.../storm/solr/trident/SolrStateFactory.java | 2 +-
.../storm/flux/model/ConfigMethodDef.java | 2 +-
.../org/apache/storm/flux/model/ObjectDef.java | 2 +-
.../flux/examples/StatefulWordCounter.java | 1 -
.../apache/storm/flux/examples/WordCounter.java | 1 -
.../apache/storm/st/wrapper/StormCluster.java | 2 +-
.../src/jvm/org/apache/storm/Config.java | 6 ++--
.../jvm/org/apache/storm/StormSubmitter.java | 5 ++-
.../src/jvm/org/apache/storm/Thrift.java | 4 +--
.../org/apache/storm/cluster/ClusterUtils.java | 6 ++--
.../cluster/PaceMakerStateStorageFactory.java | 2 +-
.../storm/cluster/StateStorageFactory.java | 2 +-
.../apache/storm/cluster/ZKStateStorage.java | 4 +--
.../storm/cluster/ZKStateStorageFactory.java | 2 +-
.../org/apache/storm/daemon/StormCommon.java | 2 +-
.../daemon/metrics/BuiltinMetricsUtil.java | 19 +++++-----
.../apache/storm/daemon/worker/WorkerState.java | 4 +--
.../jvm/org/apache/storm/drpc/DRPCSpout.java | 4 +--
.../jvm/org/apache/storm/drpc/JoinResult.java | 2 +-
.../org/apache/storm/drpc/PrepareRequest.java | 2 +-
.../org/apache/storm/drpc/ReturnResults.java | 6 ++--
.../jvm/org/apache/storm/executor/Executor.java | 32 ++++++++++-------
.../storm/executor/bolt/BoltExecutor.java | 6 ++--
.../DeserializingConnectionCallback.java | 4 +--
.../apache/storm/messaging/local/Context.java | 2 --
.../apache/storm/messaging/netty/Client.java | 3 +-
.../apache/storm/messaging/netty/Context.java | 2 --
.../apache/storm/messaging/netty/Server.java | 2 --
.../jvm/org/apache/storm/metric/SystemBolt.java | 2 +-
.../storm/metric/api/MultiCountMetric.java | 4 +--
.../storm/metric/api/MultiReducedMetric.java | 4 +--
.../storm/security/auth/FixedGroupsMapping.java | 2 +-
.../auth/authorizer/DRPCAuthorizerBase.java | 6 ++--
.../authorizer/DRPCSimpleACLAuthorizer.java | 6 ++--
.../serialization/types/HashMapSerializer.java | 4 +--
.../jvm/org/apache/storm/stats/CommonStats.java | 4 +--
.../storm/task/GeneralTopologyContext.java | 2 +-
.../storm/testing/NonRichBoltTracker.java | 2 +-
.../org/apache/storm/testing/SpoutTracker.java | 6 ++--
.../apache/storm/topology/TopologyBuilder.java | 4 +--
.../state/TestTransactionalState.java | 2 +-
.../transactional/state/TransactionalState.java | 8 ++---
.../apache/storm/trident/TridentTopology.java | 12 +++----
.../trident/drpc/ReturnResultsReducer.java | 4 +--
.../topology/state/TransactionalState.java | 8 +++--
.../jvm/org/apache/storm/utils/ConfigUtils.java | 4 +--
.../src/jvm/org/apache/storm/utils/JCQueue.java | 3 +-
.../org/apache/storm/utils/NimbusClient.java | 2 +-
.../src/jvm/org/apache/storm/utils/Utils.java | 11 +++---
.../apache/storm/zookeeper/ClientZookeeper.java | 8 ++---
.../DeserializingConnectionCallbackTest.java | 4 +--
.../apache/storm/security/auth/AutoSSLTest.java | 10 +++---
.../apache/storm/streams/ProcessorBoltTest.java | 3 +-
.../jvm/org/apache/storm/utils/UtilsTest.java | 12 +++----
.../apache/storm/command/UploadCredentials.java | 9 +++--
.../apache/storm/ui/FilterConfiguration.java | 10 +++---
.../src/jvm/org/apache/storm/ui/UIHelpers.java | 6 ++--
.../nimbus/InMemoryTopologyActionNotifier.java | 2 +-
.../storm/serialization/SerializationTest.java | 12 +++----
.../src/main/java/org/apache/storm/Testing.java | 1 -
.../org/apache/storm/daemon/nimbus/Nimbus.java | 6 ++--
.../apache/storm/metricstore/MetricStore.java | 2 +-
.../storm/metricstore/MetricStoreConfig.java | 2 +-
.../metricstore/NimbusMetricProcessor.java | 2 +-
.../metricstore/WorkerMetricsProcessor.java | 2 +-
.../storm/metricstore/rocksdb/RocksDbStore.java | 6 ++--
.../storm/nimbus/DefaultTopologyValidator.java | 4 ++-
.../nimbus/ITopologyActionNotifierPlugin.java | 2 +-
.../apache/storm/nimbus/ITopologyValidator.java | 4 ++-
.../storm/scheduler/DefaultScheduler.java | 2 +-
.../apache/storm/scheduler/EvenScheduler.java | 2 +-
.../org/apache/storm/scheduler/IScheduler.java | 2 +-
.../storm/scheduler/IsolationScheduler.java | 2 +-
.../scheduler/blacklist/BlacklistScheduler.java | 7 ++--
.../strategies/DefaultBlacklistStrategy.java | 2 +-
.../strategies/IBlacklistStrategy.java | 2 +-
.../multitenant/MultitenantScheduler.java | 7 ++--
.../resource/ResourceAwareScheduler.java | 4 +--
.../utils/ArtifactoryConfigLoader.java | 22 ++++++------
.../storm/scheduler/utils/FileConfigLoader.java | 6 ++--
.../org/apache/storm/utils/ServerUtils.java | 2 +-
.../scheduler/blacklist/FaultGenerateUtils.java | 2 +-
.../TestUtilsForBlacklistScheduler.java | 16 ++++-----
.../utils/ArtifactoryConfigLoaderTest.java | 20 +++++------
.../scheduler/utils/FileConfigLoaderTest.java | 10 +++---
.../logviewer/webapp/LogviewerResource.java | 4 +--
170 files changed, 397 insertions(+), 376 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0fdad2c0/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ThroughputVsLatency.java
----------------------------------------------------------------------