Merge branch 'fix-style' of https://github.com/kishorvpatil/incubator-storm into STORM-3037
STORM-3037: Lowering CheckStyle Violations across all modules This closes #2641 Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4137328b Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4137328b Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4137328b Branch: refs/heads/master Commit: 4137328b75c06771f84414c3c2113e2d1c757c08 Parents: 7673253 d9ca88a Author: Robert Evans <[email protected]> Authored: Thu Apr 26 15:27:49 2018 -0500 Committer: Robert Evans <[email protected]> Committed: Thu Apr 26 15:27:49 2018 -0500 ---------------------------------------------------------------------- examples/storm-hbase-examples/pom.xml | 5 +- .../storm/hbase/topology/LookupWordCount.java | 28 +- .../hbase/topology/PersistentWordCount.java | 36 +- .../storm/hbase/topology/TotalWordCounter.java | 31 +- .../storm/hbase/topology/WordCountClient.java | 21 +- .../hbase/topology/WordCountValueMapper.java | 43 +- .../storm/hbase/topology/WordCounter.java | 22 +- .../apache/storm/hbase/topology/WordSpout.java | 28 +- .../storm/hbase/trident/PrintFunction.java | 28 +- .../storm/hbase/trident/WordCountTrident.java | 57 +- examples/storm-hdfs-examples/pom.xml | 2 +- .../storm/hdfs/bolt/HdfsFileTopology.java | 54 +- .../storm/hdfs/bolt/SequenceFileTopology.java | 58 +- .../storm/hdfs/spout/HdfsSpoutTopology.java | 307 ++- .../storm/hdfs/trident/FixedBatchSpout.java | 29 +- .../storm/hdfs/trident/TridentFileTopology.java | 30 +- .../hdfs/trident/TridentSequenceTopology.java | 30 +- examples/storm-perf/pom.xml | 2 +- .../perf/ConstSpoutIdBoltNullBoltTopo.java | 12 +- .../storm/perf/ConstSpoutNullBoltTopo.java | 4 +- .../storm/perf/FileReadWordCountTopo.java | 33 +- .../storm/perf/HdfsSpoutNullBoltTopo.java | 3 +- .../org/apache/storm/perf/JCQueuePerfTest.java | 31 +- .../org/apache/storm/perf/JCToolsPerfTest.java | 27 +- .../apache/storm/perf/KafkaClientHdfsTopo.java | 8 +- .../perf/KafkaClientSpoutNullBoltTopo.java | 15 +- .../apache/storm/perf/LowThroughputTopo.java | 9 +- .../storm/perf/SimplifiedWordCountTopo.java | 1 - .../storm/perf/StrGenSpoutHdfsBoltTopo.java | 3 +- .../org/apache/storm/perf/ThroughputMeter.java | 16 +- .../org/apache/storm/perf/bolt/CountBolt.java | 1 - .../org/apache/storm/perf/bolt/DevNullBolt.java | 1 - .../java/org/apache/storm/perf/bolt/IdBolt.java | 1 - .../storm/perf/bolt/SplitSentenceBolt.java | 1 - .../org/apache/storm/perf/spout/ConstSpout.java | 1 - .../apache/storm/perf/spout/FileReadSpout.java | 1 - .../apache/storm/perf/spout/StringGenSpout.java | 27 +- .../apache/storm/perf/spout/WordGenSpout.java | 62 +- .../storm/perf/utils/BasicMetricsCollector.java | 23 +- .../org/apache/storm/perf/utils/Helper.java | 7 +- .../apache/storm/perf/utils/IdentityBolt.java | 3 +- .../apache/storm/perf/utils/MetricsSample.java | 3 +- examples/storm-starter/pom.xml | 2 +- .../apache/storm/starter/AnchoredWordCount.java | 72 +- .../apache/storm/starter/BasicDRPCTopology.java | 49 +- .../starter/BlobStoreAPIWordCountTopology.java | 276 ++- .../storm/starter/ExclamationTopology.java | 84 +- .../storm/starter/FastWordCountTopology.java | 300 +-- .../storm/starter/InOrderDeliveryTest.java | 261 +-- .../apache/storm/starter/JoinBoltExample.java | 39 +- .../apache/storm/starter/LambdaTopology.java | 24 +- .../org/apache/storm/starter/ManualDRPC.java | 51 +- .../storm/starter/MultipleLoggerTopology.java | 112 +- .../starter/PersistentWindowingTopology.java | 99 +- .../org/apache/storm/starter/ReachTopology.java | 76 +- .../starter/ResourceAwareExampleTopology.java | 113 +- .../apache/storm/starter/RollingTopWords.java | 111 +- .../apache/storm/starter/SingleJoinExample.java | 26 +- .../storm/starter/SkewedRollingTopWords.java | 113 +- .../storm/starter/SlidingTupleTsTopology.java | 30 +- .../storm/starter/SlidingWindowTopology.java | 62 +- .../apache/storm/starter/StatefulTopology.java | 44 +- .../starter/StatefulWindowingTopology.java | 46 +- .../storm/starter/TransactionalGlobalCount.java | 65 +- .../storm/starter/TransactionalWords.java | 102 +- .../apache/storm/starter/WordCountTopology.java | 115 +- .../storm/starter/WordCountTopologyNode.java | 61 +- .../storm/starter/bolt/AbstractRankerBolt.java | 135 +- .../starter/bolt/IntermediateRankingsBolt.java | 61 +- .../apache/storm/starter/bolt/PrinterBolt.java | 33 +- .../storm/starter/bolt/RollingCountAggBolt.java | 92 +- .../storm/starter/bolt/RollingCountBolt.java | 169 +- .../storm/starter/bolt/SingleJoinBolt.java | 167 +- .../starter/bolt/SlidingWindowSumBolt.java | 48 +- .../storm/starter/bolt/TotalRankingsBolt.java | 63 +- .../storm/starter/spout/RandomIntegerSpout.java | 24 +- .../spout/RandomNumberGeneratorSpout.java | 35 +- .../starter/spout/RandomSentenceSpout.java | 120 +- .../storm/starter/streams/AggregateExample.java | 33 +- .../storm/starter/streams/BranchExample.java | 45 +- .../streams/GroupByKeyAndWindowExample.java | 62 +- .../storm/starter/streams/JoinExample.java | 48 +- .../starter/streams/StateQueryExample.java | 53 +- .../starter/streams/StatefulWordCount.java | 59 +- .../starter/streams/TypedTupleExample.java | 19 +- .../starter/streams/WindowedWordCount.java | 70 +- .../storm/starter/streams/WordCountToBolt.java | 51 +- .../tools/NthLastModifiedTimeTracker.java | 75 +- .../apache/storm/starter/tools/Rankable.java | 35 +- .../starter/tools/RankableObjectWithFields.java | 224 +- .../apache/storm/starter/tools/Rankings.java | 238 +- .../starter/tools/SlidingWindowCounter.java | 101 +- .../storm/starter/tools/SlotBasedCounter.java | 144 +- .../starter/trident/DebugMemoryMapState.java | 7 +- .../TridentHBaseWindowingStoreTopology.java | 46 +- .../starter/trident/TridentMapExample.java | 50 +- .../trident/TridentMinMaxOfDevicesTopology.java | 85 +- .../TridentMinMaxOfVehiclesTopology.java | 83 +- .../storm/starter/trident/TridentReach.java | 95 +- .../TridentWindowingInmemoryStoreTopology.java | 43 +- .../storm/starter/trident/TridentWordCount.java | 58 +- .../bolt/IntermediateRankingsBoltTest.java | 244 ++- .../starter/bolt/RollingCountBoltTest.java | 178 +- .../starter/bolt/TotalRankingsBoltTest.java | 246 ++- .../tools/NthLastModifiedTimeTrackerTest.java | 158 +- .../tools/RankableObjectWithFieldsTest.java | 489 +++-- .../storm/starter/tools/RankingsTest.java | 668 +++--- .../starter/tools/SlidingWindowCounterTest.java | 175 +- .../starter/tools/SlotBasedCounterTest.java | 320 ++- external/storm-cassandra/pom.xml | 2 +- .../AbstractExecutionResultHandler.java | 34 +- .../cassandra/BaseExecutionResultHandler.java | 32 +- .../storm/cassandra/CassandraContext.java | 28 +- .../cassandra/DynamicStatementBuilder.java | 38 +- .../storm/cassandra/ExecutionResultHandler.java | 27 +- .../storm/cassandra/Murmur3StreamGrouping.java | 87 +- .../storm/cassandra/bolt/BaseCassandraBolt.java | 42 +- .../bolt/BatchCassandraWriterBolt.java | 80 +- .../cassandra/bolt/CassandraWriterBolt.java | 34 +- .../cassandra/bolt/GroupingBatchBuilder.java | 29 +- .../bolt/PairBatchStatementTuples.java | 23 +- .../cassandra/bolt/PairStatementTuple.java | 26 +- .../storm/cassandra/client/CassandraConf.java | 191 +- .../storm/cassandra/client/ClusterFactory.java | 46 +- .../storm/cassandra/client/SimpleClient.java | 20 +- .../cassandra/client/SimpleClientProvider.java | 20 +- .../cassandra/client/impl/DefaultClient.java | 27 +- .../cassandra/context/BaseBeanFactory.java | 25 +- .../storm/cassandra/context/BeanFactory.java | 20 +- .../storm/cassandra/context/WorkerCtx.java | 32 +- .../storm/cassandra/executor/AsyncExecutor.java | 98 +- .../executor/AsyncExecutorProvider.java | 22 +- .../cassandra/executor/AsyncResultHandler.java | 27 +- .../executor/AsyncResultSetHandler.java | 23 +- .../executor/ExecutionResultCollector.java | 36 +- .../executor/impl/BatchAsyncResultHandler.java | 32 +- .../executor/impl/SingleAsyncResultHandler.java | 30 +- .../query/AyncCQLResultSetValuesMapper.java | 25 +- .../query/BaseCQLStatementTupleMapper.java | 23 +- .../query/CQLResultSetValuesMapper.java | 25 +- .../cassandra/query/CQLStatementBuilder.java | 20 +- .../query/CQLStatementTupleMapper.java | 25 +- .../apache/storm/cassandra/query/Column.java | 34 +- .../storm/cassandra/query/ContextQuery.java | 23 +- .../apache/storm/cassandra/query/CqlMapper.java | 29 +- .../cassandra/query/ObjectMapperOperation.java | 19 +- .../builder/BoundCQLStatementMapperBuilder.java | 33 +- .../ObjectMapperCqlStatementMapperBuilder.java | 19 +- .../SimpleCQLStatementMapperBuilder.java | 31 +- .../impl/BatchCQLStatementTupleMapper.java | 29 +- .../impl/BoundCQLStatementTupleMapper.java | 48 +- .../impl/ObjectMapperCqlStatementMapper.java | 27 +- .../query/impl/PreparedStatementBinder.java | 40 +- .../query/impl/RoutingKeyGenerator.java | 25 +- .../query/impl/SimpleCQLStatementMapper.java | 36 +- .../cassandra/query/selector/FieldSelector.java | 25 +- .../trident/state/CassandraBackingMap.java | 49 +- .../trident/state/CassandraMapStateFactory.java | 29 +- .../cassandra/trident/state/CassandraQuery.java | 25 +- .../cassandra/trident/state/CassandraState.java | 91 +- .../trident/state/CassandraStateFactory.java | 28 +- .../trident/state/CassandraStateUpdater.java | 23 +- .../trident/state/MapStateFactoryBuilder.java | 85 +- .../state/NonTransactionalTupleStateMapper.java | 23 +- .../trident/state/OpaqueTupleStateMapper.java | 31 +- .../trident/state/SerializedStateMapper.java | 31 +- .../trident/state/SimpleStateMapper.java | 26 +- .../cassandra/trident/state/SimpleTuple.java | 38 +- .../cassandra/trident/state/StateMapper.java | 25 +- .../state/TransactionalTupleStateMapper.java | 28 +- .../TridentAyncCQLResultSetValuesMapper.java | 28 +- .../state/TridentResultSetValuesMapper.java | 29 +- .../apache/storm/cassandra/WeatherSpout.java | 25 +- .../testtools/EmbeddedCassandraResource.java | 33 +- .../storm/cassandra/trident/MapStateTest.java | 103 +- .../cassandra/trident/WeatherBatchSpout.java | 43 +- external/storm-eventhubs/pom.xml | 2 +- .../eventhubs/bolt/DefaultEventDataFormat.java | 38 +- .../storm/eventhubs/bolt/EventHubBolt.java | 208 +- .../eventhubs/bolt/EventHubBoltConfig.java | 147 +- .../storm/eventhubs/bolt/IEventDataFormat.java | 3 +- .../eventhubs/spout/BinaryEventDataScheme.java | 78 +- .../storm/eventhubs/spout/EventDataScheme.java | 92 +- .../storm/eventhubs/spout/EventDataWrap.java | 51 +- .../storm/eventhubs/spout/EventHubFilter.java | 11 +- .../eventhubs/spout/EventHubReceiverImpl.java | 237 +- .../storm/eventhubs/spout/EventHubSpout.java | 420 ++-- .../eventhubs/spout/EventHubSpoutConfig.java | 451 ++-- .../storm/eventhubs/spout/FieldConstants.java | 13 +- .../storm/eventhubs/spout/IEventDataScheme.java | 34 +- .../eventhubs/spout/IEventHubReceiver.java | 11 +- .../spout/IEventHubReceiverFactory.java | 27 +- .../eventhubs/spout/IPartitionCoordinator.java | 5 +- .../eventhubs/spout/IPartitionManager.java | 17 +- .../spout/IPartitionManagerFactory.java | 33 +- .../storm/eventhubs/spout/IStateStore.java | 9 +- .../apache/storm/eventhubs/spout/MessageId.java | 69 +- .../storm/eventhubs/spout/PartitionManager.java | 126 +- .../eventhubs/spout/SimplePartitionManager.java | 200 +- .../spout/StaticPartitionCoordinator.java | 92 +- .../eventhubs/spout/StringEventDataScheme.java | 78 +- .../eventhubs/spout/ZookeeperStateStore.java | 107 +- .../storm/eventhubs/trident/Coordinator.java | 65 +- .../trident/ITridentPartitionManager.java | 26 +- .../ITridentPartitionManagerFactory.java | 4 +- .../trident/OpaqueTridentEventHubEmitter.java | 69 +- .../trident/OpaqueTridentEventHubSpout.java | 65 +- .../storm/eventhubs/trident/Partition.java | 23 +- .../storm/eventhubs/trident/Partitions.java | 28 +- .../TransactionalTridentEventHubEmitter.java | 240 ++- .../TransactionalTridentEventHubSpout.java | 64 +- .../trident/TridentPartitionManager.java | 117 +- .../eventhubs/samples/AtMostOnceEventCount.java | 44 +- .../storm/eventhubs/samples/EventCount.java | 208 +- .../storm/eventhubs/samples/EventHubLoop.java | 44 +- .../samples/OpaqueTridentEventCount.java | 45 +- .../samples/TransactionalTridentEventCount.java | 86 +- .../eventhubs/samples/bolt/GlobalCountBolt.java | 95 +- .../samples/bolt/PartialCountBolt.java | 59 +- .../eventhubs/spout/EventHubReceiverMock.java | 97 +- .../spout/EventHubSpoutCallerMock.java | 130 +- .../spout/PartitionManagerCallerMock.java | 134 +- .../spout/SpoutOutputCollectorMock.java | 76 +- .../storm/eventhubs/spout/StateStoreMock.java | 44 +- .../storm/eventhubs/spout/TestEventData.java | 29 +- .../eventhubs/spout/TestEventHubSpout.java | 82 +- .../eventhubs/spout/TestPartitionManager.java | 178 +- .../TestTransactionalTridentEmitter.java | 123 +- .../eventhubs/trident/TridentCollectorMock.java | 58 +- external/storm-hbase/pom.xml | 2 +- .../storm/hbase/bolt/AbstractHBaseBolt.java | 42 +- .../org/apache/storm/hbase/bolt/HBaseBolt.java | 42 +- .../storm/hbase/bolt/HBaseLookupBolt.java | 161 +- .../storm/hbase/bolt/mapper/HBaseMapper.java | 27 +- .../bolt/mapper/HBaseProjectionCriteria.java | 75 +- .../hbase/bolt/mapper/HBaseValueMapper.java | 31 +- .../hbase/bolt/mapper/SimpleHBaseMapper.java | 55 +- .../apache/storm/hbase/common/ColumnList.java | 166 +- .../apache/storm/hbase/common/HBaseClient.java | 42 +- .../org/apache/storm/hbase/common/IColumn.java | 26 +- .../org/apache/storm/hbase/common/ICounter.java | 25 +- .../org/apache/storm/hbase/common/Utils.java | 83 +- .../storm/hbase/state/HBaseKeyValueState.java | 36 +- .../hbase/state/HBaseKeyValueStateIterator.java | 42 +- .../hbase/state/HBaseKeyValueStateProvider.java | 31 +- .../mapper/SimpleTridentHBaseMapMapper.java | 2 +- .../mapper/SimpleTridentHBaseMapper.java | 45 +- .../trident/mapper/TridentHBaseMapper.java | 34 +- .../hbase/trident/state/HBaseMapState.java | 142 +- .../storm/hbase/trident/state/HBaseQuery.java | 24 +- .../storm/hbase/trident/state/HBaseState.java | 125 +- .../hbase/trident/state/HBaseStateFactory.java | 24 +- .../storm/hbase/trident/state/HBaseUpdater.java | 24 +- .../trident/windowing/HBaseWindowsStore.java | 65 +- .../windowing/HBaseWindowsStoreFactory.java | 24 +- .../storm/hbase/state/HBaseClientTestUtil.java | 38 +- .../state/HBaseKeyValueStateIteratorTest.java | 28 +- .../state/HBaseKeyValueStateProviderTest.java | 15 +- .../hbase/state/HBaseKeyValueStateTest.java | 35 +- external/storm-hdfs/pom.xml | 2 +- .../storm/hdfs/avro/AbstractAvroSerializer.java | 33 +- .../storm/hdfs/avro/AvroSchemaRegistry.java | 22 +- .../org/apache/storm/hdfs/avro/AvroUtils.java | 24 +- .../hdfs/avro/ConfluentAvroSerializer.java | 24 +- .../storm/hdfs/avro/FixedAvroSerializer.java | 30 +- .../storm/hdfs/avro/GenericAvroSerializer.java | 19 +- .../storm/hdfs/bolt/AbstractHdfsBolt.java | 79 +- .../storm/hdfs/bolt/AvroGenericRecordBolt.java | 52 +- .../org/apache/storm/hdfs/bolt/HdfsBolt.java | 51 +- .../storm/hdfs/bolt/SequenceFileBolt.java | 50 +- .../java/org/apache/storm/hdfs/bolt/Writer.java | 18 +- .../hdfs/bolt/format/DefaultFileNameFormat.java | 32 +- .../hdfs/bolt/format/DefaultSequenceFormat.java | 12 +- .../hdfs/bolt/format/DelimitedRecordFormat.java | 29 +- .../storm/hdfs/bolt/format/FileNameFormat.java | 22 +- .../storm/hdfs/bolt/format/RecordFormat.java | 22 +- .../storm/hdfs/bolt/format/SequenceFormat.java | 7 +- .../hdfs/bolt/format/SimpleFileNameFormat.java | 38 +- .../hdfs/bolt/rotation/FileRotationPolicy.java | 22 +- .../bolt/rotation/FileSizeRotationPolicy.java | 62 +- .../hdfs/bolt/rotation/NoRotationPolicy.java | 19 +- .../hdfs/bolt/rotation/TimedRotationPolicy.java | 43 +- .../storm/hdfs/bolt/sync/CountSyncPolicy.java | 21 +- .../apache/storm/hdfs/bolt/sync/SyncPolicy.java | 22 +- .../storm/hdfs/common/AbstractHDFSWriter.java | 22 +- .../common/AvroGenericRecordHDFSWriter.java | 24 +- .../apache/storm/hdfs/common/HDFSWriter.java | 26 +- .../org/apache/storm/hdfs/common/HdfsUtils.java | 137 +- .../storm/hdfs/common/ModifTimeComparator.java | 27 +- .../storm/hdfs/common/NullPartitioner.java | 19 +- .../apache/storm/hdfs/common/Partitioner.java | 24 +- .../storm/hdfs/common/SequenceFileWriter.java | 24 +- .../hdfs/common/rotation/MoveFileAction.java | 6 +- .../hdfs/common/rotation/RotationAction.java | 6 +- .../storm/hdfs/spout/AbstractFileReader.java | 70 +- .../org/apache/storm/hdfs/spout/Configs.java | 45 +- .../org/apache/storm/hdfs/spout/DirLock.java | 182 +- .../org/apache/storm/hdfs/spout/FileLock.java | 563 ++--- .../org/apache/storm/hdfs/spout/FileOffset.java | 25 +- .../org/apache/storm/hdfs/spout/FileReader.java | 49 +- .../org/apache/storm/hdfs/spout/HdfsSpout.java | 161 +- .../apache/storm/hdfs/spout/ParseException.java | 24 +- .../storm/hdfs/spout/ProgressTracker.java | 86 +- .../storm/hdfs/spout/SequenceFileReader.java | 340 ++- .../apache/storm/hdfs/spout/TextFileReader.java | 304 ++- .../apache/storm/hdfs/trident/HdfsState.java | 322 +-- .../storm/hdfs/trident/HdfsStateFactory.java | 12 +- .../apache/storm/hdfs/trident/HdfsUpdater.java | 6 +- .../trident/format/DefaultFileNameFormat.java | 29 +- .../trident/format/DefaultSequenceFormat.java | 11 +- .../trident/format/DelimitedRecordFormat.java | 31 +- .../hdfs/trident/format/FileNameFormat.java | 19 +- .../storm/hdfs/trident/format/RecordFormat.java | 22 +- .../hdfs/trident/format/SequenceFormat.java | 7 +- .../trident/format/SimpleFileNameFormat.java | 36 +- .../trident/rotation/FileRotationPolicy.java | 24 +- .../rotation/FileSizeRotationPolicy.java | 64 +- .../hdfs/trident/rotation/NoRotationPolicy.java | 19 +- .../trident/rotation/TimedRotationPolicy.java | 49 +- .../hdfs/trident/sync/CountSyncPolicy.java | 21 +- .../storm/hdfs/trident/sync/SyncPolicy.java | 22 +- .../hdfs/avro/TestFixedAvroSerializer.java | 44 +- .../hdfs/avro/TestGenericAvroSerializer.java | 33 +- .../hdfs/bolt/AvroGenericRecordBoltTest.java | 129 +- .../apache/storm/hdfs/bolt/TestHdfsBolt.java | 135 +- .../storm/hdfs/bolt/TestSequenceFileBolt.java | 115 +- .../apache/storm/hdfs/bolt/TestWritersMap.java | 22 +- .../bolt/format/TestSimpleFileNameFormat.java | 39 +- .../apache/storm/hdfs/spout/ConfigsTest.java | 46 +- .../apache/storm/hdfs/spout/TestDirLock.java | 29 +- .../apache/storm/hdfs/spout/TestFileLock.java | 47 +- .../storm/hdfs/spout/TestHdfsSemantics.java | 35 +- .../apache/storm/hdfs/spout/TestHdfsSpout.java | 201 +- .../storm/hdfs/spout/TestProgressTracker.java | 21 +- .../storm/hdfs/testing/MiniDFSClusterRule.java | 8 +- .../storm/hdfs/trident/HdfsStateTest.java | 103 +- .../format/TestSimpleFileNameFormat.java | 30 +- external/storm-hive/pom.xml | 2 +- .../org/apache/storm/hive/bolt/HiveBolt.java | 139 +- .../bolt/mapper/DelimitedRecordHiveMapper.java | 60 +- .../storm/hive/bolt/mapper/HiveMapper.java | 30 +- .../hive/bolt/mapper/JsonRecordHiveMapper.java | 61 +- .../apache/storm/hive/common/HiveOptions.java | 24 +- .../org/apache/storm/hive/common/HiveUtils.java | 60 +- .../apache/storm/hive/common/HiveWriter.java | 255 ++- .../apache/storm/hive/trident/HiveState.java | 124 +- .../storm/hive/trident/HiveStateFactory.java | 31 +- .../apache/storm/hive/trident/HiveUpdater.java | 23 +- .../apache/storm/hive/bolt/HiveSetupUtil.java | 143 +- .../apache/storm/hive/bolt/TestHiveBolt.java | 302 ++- .../storm/hive/common/TestHiveWriter.java | 205 +- external/storm-jdbc/pom.xml | 2 +- .../storm/jdbc/bolt/AbstractJdbcBolt.java | 55 +- .../apache/storm/jdbc/bolt/JdbcInsertBolt.java | 42 +- .../apache/storm/jdbc/bolt/JdbcLookupBolt.java | 29 +- .../org/apache/storm/jdbc/common/Column.java | 27 +- .../storm/jdbc/common/ConnectionProvider.java | 19 +- .../jdbc/common/HikariCPConnectionProvider.java | 30 +- .../apache/storm/jdbc/common/JdbcClient.java | 39 +- .../java/org/apache/storm/jdbc/common/Util.java | 19 +- .../storm/jdbc/mapper/JdbcLookupMapper.java | 24 +- .../apache/storm/jdbc/mapper/JdbcMapper.java | 24 +- .../jdbc/mapper/SimpleJdbcLookupMapper.java | 36 +- .../storm/jdbc/mapper/SimpleJdbcMapper.java | 57 +- .../storm/jdbc/trident/state/JdbcQuery.java | 24 +- .../storm/jdbc/trident/state/JdbcState.java | 141 +- .../jdbc/trident/state/JdbcStateFactory.java | 24 +- .../storm/jdbc/trident/state/JdbcUpdater.java | 24 +- .../storm/jdbc/bolt/JdbcInsertBoltTest.java | 28 +- .../storm/jdbc/bolt/JdbcLookupBoltTest.java | 29 +- .../storm/jdbc/common/JdbcClientTest.java | 63 +- .../org/apache/storm/jdbc/common/UtilTest.java | 22 +- external/storm-jms/pom.xml | 2 +- .../apache/storm/jms/JmsMessageProducer.java | 21 +- .../java/org/apache/storm/jms/JmsProvider.java | 20 +- .../org/apache/storm/jms/JmsTupleProducer.java | 21 +- .../java/org/apache/storm/jms/bolt/JmsBolt.java | 38 +- .../apache/storm/jms/spout/JmsMessageID.java | 29 +- .../org/apache/storm/jms/spout/JmsSpout.java | 216 +- .../org/apache/storm/jms/trident/JmsBatch.java | 19 +- .../org/apache/storm/jms/trident/JmsState.java | 103 +- .../storm/jms/trident/JmsStateFactory.java | 22 +- .../apache/storm/jms/trident/JmsUpdater.java | 26 +- .../storm/jms/trident/TridentJmsSpout.java | 237 +- .../apache/storm/jms/spout/JmsSpoutTest.java | 37 +- .../apache/storm/jms/spout/MockJmsProvider.java | 21 +- .../jms/spout/MockSpoutOutputCollector.java | 6 +- .../storm/jms/spout/MockTupleProducer.java | 2 +- external/storm-kafka-monitor/pom.xml | 2 +- .../kafka/monitor/KafkaOffsetLagResult.java | 14 +- .../storm/kafka/monitor/KafkaOffsetLagUtil.java | 203 +- .../kafka/monitor/KafkaPartitionOffsetLag.java | 81 +- .../kafka/monitor/NewKafkaSpoutOffsetQuery.java | 12 +- .../kafka/monitor/OldKafkaSpoutOffsetQuery.java | 25 +- external/storm-kafka/pom.xml | 2 +- .../src/jvm/org/apache/storm/kafka/Broker.java | 51 +- .../jvm/org/apache/storm/kafka/BrokerHosts.java | 19 +- .../storm/kafka/ByteBufferSerializer.java | 26 +- .../storm/kafka/DynamicBrokersReader.java | 112 +- .../kafka/DynamicPartitionConnections.java | 55 +- .../ExponentialBackoffMsgRetryManager.java | 75 +- .../storm/kafka/FailedFetchException.java | 19 +- .../storm/kafka/FailedMsgRetryManager.java | 19 +- .../org/apache/storm/kafka/IntSerializer.java | 24 +- .../jvm/org/apache/storm/kafka/KafkaConfig.java | 25 +- .../jvm/org/apache/storm/kafka/KafkaError.java | 19 +- .../jvm/org/apache/storm/kafka/KafkaSpout.java | 58 +- .../jvm/org/apache/storm/kafka/KafkaUtils.java | 269 ++- .../org/apache/storm/kafka/KeyValueScheme.java | 22 +- .../kafka/KeyValueSchemeAsMultiScheme.java | 31 +- .../storm/kafka/MessageMetadataScheme.java | 22 +- .../MessageMetadataSchemeAsMultiScheme.java | 20 +- .../jvm/org/apache/storm/kafka/Partition.java | 39 +- .../storm/kafka/PartitionCoordinator.java | 19 +- .../apache/storm/kafka/PartitionManager.java | 121 +- .../jvm/org/apache/storm/kafka/SpoutConfig.java | 19 +- .../apache/storm/kafka/StaticCoordinator.java | 27 +- .../jvm/org/apache/storm/kafka/StaticHosts.java | 19 +- .../storm/kafka/StaticPartitionConnections.java | 22 +- .../storm/kafka/StringKeyValueScheme.java | 24 +- .../kafka/StringMessageAndMetadataScheme.java | 27 +- .../storm/kafka/StringMultiSchemeWithTopic.java | 28 +- .../org/apache/storm/kafka/StringScheme.java | 38 +- .../kafka/TopicOffsetOutOfRangeException.java | 1 + .../org/apache/storm/kafka/ZkCoordinator.java | 50 +- .../src/jvm/org/apache/storm/kafka/ZkHosts.java | 19 +- .../src/jvm/org/apache/storm/kafka/ZkState.java | 65 +- .../org/apache/storm/kafka/bolt/KafkaBolt.java | 69 +- .../FieldNameBasedTupleToKafkaMapper.java | 21 +- .../kafka/bolt/mapper/TupleToKafkaMapper.java | 25 +- .../bolt/selector/DefaultTopicSelector.java | 19 +- .../bolt/selector/FieldIndexTopicSelector.java | 19 +- .../bolt/selector/FieldNameTopicSelector.java | 19 +- .../kafka/bolt/selector/KafkaTopicSelector.java | 22 +- .../apache/storm/kafka/trident/Coordinator.java | 27 +- .../storm/kafka/trident/DefaultCoordinator.java | 19 +- .../trident/GlobalPartitionInformation.java | 41 +- .../storm/kafka/trident/IBatchCoordinator.java | 19 +- .../storm/kafka/trident/IBrokerReader.java | 20 +- .../apache/storm/kafka/trident/MaxMetric.java | 19 +- .../kafka/trident/OpaqueTridentKafkaSpout.java | 44 +- .../storm/kafka/trident/StaticBrokerReader.java | 23 +- .../trident/TransactionalTridentKafkaSpout.java | 22 +- .../storm/kafka/trident/TridentKafkaConfig.java | 19 +- .../kafka/trident/TridentKafkaEmitter.java | 73 +- .../storm/kafka/trident/TridentKafkaState.java | 49 +- .../kafka/trident/TridentKafkaStateFactory.java | 34 +- .../kafka/trident/TridentKafkaUpdater.java | 22 +- .../storm/kafka/trident/ZkBrokerReader.java | 113 +- .../FieldNameBasedTupleToKafkaMapper.java | 19 +- .../mapper/TridentTupleToKafkaMapper.java | 26 +- .../trident/selector/DefaultTopicSelector.java | 19 +- .../trident/selector/KafkaTopicSelector.java | 22 +- .../storm/kafka/DynamicBrokersReaderTest.java | 39 +- .../ExponentialBackoffMsgRetryManagerTest.java | 49 +- .../org/apache/storm/kafka/KafkaErrorTest.java | 19 +- .../org/apache/storm/kafka/KafkaTestBroker.java | 29 +- .../org/apache/storm/kafka/KafkaUtilsTest.java | 73 +- .../storm/kafka/PartitionManagerTest.java | 34 +- .../storm/kafka/StringKeyValueSchemeTest.java | 36 +- .../apache/storm/kafka/TestStringScheme.java | 28 +- .../test/org/apache/storm/kafka/TestUtils.java | 32 +- .../apache/storm/kafka/TridentKafkaTest.java | 40 +- .../apache/storm/kafka/ZkCoordinatorTest.java | 49 +- .../apache/storm/kafka/bolt/KafkaBoltTest.java | 159 +- external/storm-mqtt/pom.xml | 2 +- .../java/org/apache/storm/mqtt/MqttLogger.java | 20 +- .../java/org/apache/storm/mqtt/MqttMessage.java | 26 +- .../apache/storm/mqtt/MqttMessageMapper.java | 22 +- .../org/apache/storm/mqtt/MqttTupleMapper.java | 24 +- .../org/apache/storm/mqtt/bolt/MqttBolt.java | 36 +- .../apache/storm/mqtt/common/MqttOptions.java | 43 +- .../apache/storm/mqtt/common/MqttPublisher.java | 28 +- .../org/apache/storm/mqtt/common/MqttUtils.java | 34 +- .../org/apache/storm/mqtt/common/SslUtils.java | 36 +- .../mqtt/mappers/ByteArrayMessageMapper.java | 23 +- .../storm/mqtt/mappers/StringMessageMapper.java | 23 +- .../apache/storm/mqtt/spout/AckableMessage.java | 49 +- .../org/apache/storm/mqtt/spout/MqttSpout.java | 86 +- .../storm/mqtt/ssl/DefaultKeyStoreLoader.java | 25 +- .../apache/storm/mqtt/ssl/KeyStoreLoader.java | 23 +- .../storm/mqtt/trident/MqttPublishFunction.java | 33 +- .../storm/mqtt/StormMqttIntegrationTest.java | 75 +- external/storm-redis/pom.xml | 2 +- .../storm/redis/bolt/AbstractRedisBolt.java | 28 +- .../storm/redis/bolt/RedisFilterBolt.java | 22 +- .../storm/redis/bolt/RedisLookupBolt.java | 30 +- .../apache/storm/redis/bolt/RedisStoreBolt.java | 19 +- .../adapter/RedisCommandsAdapterJedis.java | 7 +- .../RedisCommandsAdapterJedisCluster.java | 7 +- .../redis/common/commands/RedisCommands.java | 9 +- .../redis/common/config/JedisClusterConfig.java | 23 +- .../redis/common/config/JedisPoolConfig.java | 44 +- .../common/container/JedisClusterContainer.java | 21 +- .../JedisCommandsContainerBuilder.java | 26 +- .../JedisCommandsInstanceContainer.java | 21 +- .../redis/common/container/JedisContainer.java | 23 +- .../common/container/RedisClusterContainer.java | 4 +- .../RedisCommandsContainerBuilder.java | 10 +- .../RedisCommandsInstanceContainer.java | 6 +- .../redis/common/container/RedisContainer.java | 6 +- .../common/mapper/RedisDataTypeDescription.java | 26 +- .../redis/common/mapper/RedisFilterMapper.java | 19 +- .../redis/common/mapper/RedisLookupMapper.java | 22 +- .../storm/redis/common/mapper/RedisMapper.java | 19 +- .../redis/common/mapper/RedisStoreMapper.java | 19 +- .../storm/redis/common/mapper/TupleMapper.java | 22 +- .../storm/redis/state/RedisKeyValueState.java | 62 +- .../redis/state/RedisKeyValueStateIterator.java | 22 +- .../redis/state/RedisKeyValueStateProvider.java | 42 +- .../trident/state/AbstractRedisMapState.java | 37 +- .../state/AbstractRedisStateQuerier.java | 25 +- .../state/AbstractRedisStateUpdater.java | 30 +- .../storm/redis/trident/state/KeyFactory.java | 21 +- .../storm/redis/trident/state/Options.java | 24 +- .../trident/state/RedisClusterMapState.java | 213 +- .../redis/trident/state/RedisClusterState.java | 99 +- .../trident/state/RedisClusterStateQuerier.java | 23 +- .../trident/state/RedisClusterStateUpdater.java | 48 +- .../redis/trident/state/RedisMapState.java | 264 ++- .../storm/redis/trident/state/RedisState.java | 92 +- .../redis/trident/state/RedisStateQuerier.java | 38 +- .../redis/trident/state/RedisStateUpdater.java | 48 +- .../state/RedisKeyValueStateIteratorTest.java | 69 +- .../state/RedisKeyValueStateProviderTest.java | 34 +- .../redis/state/RedisKeyValueStateTest.java | 186 +- external/storm-solr/pom.xml | 2 +- .../apache/storm/solr/bolt/SolrUpdateBolt.java | 30 +- .../storm/solr/config/CountBasedCommit.java | 18 +- .../storm/solr/config/SolrCommitStrategy.java | 18 +- .../apache/storm/solr/config/SolrConfig.java | 25 +- .../storm/solr/mapper/SolrFieldsMapper.java | 137 +- .../storm/solr/mapper/SolrJsonMapper.java | 119 +- .../apache/storm/solr/mapper/SolrMapper.java | 22 +- .../storm/solr/mapper/SolrMapperException.java | 18 +- .../org/apache/storm/solr/schema/CopyField.java | 32 +- .../org/apache/storm/solr/schema/Field.java | 32 +- .../org/apache/storm/solr/schema/FieldType.java | 43 +- .../org/apache/storm/solr/schema/Schema.java | 82 +- .../storm/solr/schema/SolrFieldTypeFinder.java | 87 +- .../schema/builder/RestJsonSchemaBuilder.java | 21 +- .../schema/builder/RestJsonSchemaBuilderV2.java | 49 +- .../solr/schema/builder/SchemaBuilder.java | 20 +- .../apache/storm/solr/trident/SolrState.java | 24 +- .../storm/solr/trident/SolrStateFactory.java | 19 +- .../apache/storm/solr/trident/SolrUpdater.java | 21 +- sql/storm-sql-core/pom.xml | 2 +- .../storm/sql/AbstractTridentProcessor.java | 73 +- .../src/jvm/org/apache/storm/sql/StormSql.java | 50 +- .../org/apache/storm/sql/StormSqlContext.java | 21 +- .../jvm/org/apache/storm/sql/StormSqlImpl.java | 180 +- .../org/apache/storm/sql/StormSqlRunner.java | 35 +- .../sql/calcite/ParallelStreamableTable.java | 18 +- .../apache/storm/sql/compiler/CompilerUtil.java | 262 ++- .../sql/compiler/RexNodeToJavaCodeCompiler.java | 293 +-- .../sql/compiler/StormSqlTypeFactoryImpl.java | 23 +- .../storm/sql/javac/CompilingClassLoader.java | 285 ++- .../storm/sql/parser/ColumnConstraint.java | 46 +- .../storm/sql/parser/ColumnDefinition.java | 48 +- .../storm/sql/parser/SqlCreateFunction.java | 32 +- .../apache/storm/sql/parser/SqlCreateTable.java | 258 ++- .../apache/storm/sql/parser/SqlDDLKeywords.java | 21 +- .../apache/storm/sql/parser/StormParser.java | 58 +- .../apache/storm/sql/parser/UnparseUtil.java | 75 +- .../sql/planner/StormRelDataTypeSystem.java | 18 +- .../apache/storm/sql/planner/StormRelUtils.java | 24 +- .../planner/UnsupportedOperatorsVisitor.java | 19 +- .../storm/sql/planner/rel/StormCalcRelBase.java | 18 +- .../sql/planner/rel/StormFilterRelBase.java | 18 +- .../storm/sql/planner/rel/StormJoinRelBase.java | 24 +- .../sql/planner/rel/StormProjectRelBase.java | 24 +- .../storm/sql/planner/rel/StormRelNode.java | 18 +- .../planner/rel/StormStreamInsertRelBase.java | 25 +- .../sql/planner/rel/StormStreamScanRelBase.java | 18 +- .../storm/sql/planner/trident/QueryPlanner.java | 34 +- .../sql/planner/trident/TridentPlanCreator.java | 38 +- .../planner/trident/TridentStormRuleSets.java | 68 +- .../sql/planner/trident/rel/TridentCalcRel.java | 33 +- .../planner/trident/rel/TridentFilterRel.java | 24 +- .../trident/rel/TridentLogicalConvention.java | 97 +- .../planner/trident/rel/TridentProjectRel.java | 29 +- .../sql/planner/trident/rel/TridentRel.java | 19 +- .../trident/rel/TridentStreamInsertRel.java | 34 +- .../trident/rel/TridentStreamScanRel.java | 24 +- .../trident/rules/TridentAggregateRule.java | 18 +- .../planner/trident/rules/TridentCalcRule.java | 42 +- .../trident/rules/TridentFilterRule.java | 45 +- .../planner/trident/rules/TridentJoinRule.java | 35 +- .../trident/rules/TridentModifyRule.java | 76 +- .../trident/rules/TridentProjectRule.java | 46 +- .../planner/trident/rules/TridentScanRule.java | 63 +- .../test/org/apache/storm/sql/SqlTestUtil.java | 9 +- .../storm/sql/StormSqlLocalClusterImpl.java | 17 +- .../test/org/apache/storm/sql/TestStormSql.java | 177 +- .../backends/trident/TestCompilerUtils.java | 191 +- .../backends/trident/TestExpressions.java | 238 +- .../backends/trident/TestPlanCompiler.java | 370 ++-- .../apache/storm/sql/parser/TestSqlParser.java | 66 +- .../maven-shade-clojure-transformer/pom.xml | 2 +- .../maven/shade/clojure/ClojureTransformer.java | 14 +- storm-buildtools/storm-maven-plugins/pom.xml | 2 +- .../storm/maven/plugin/util/CommandExec.java | 118 +- .../plugin/versioninfo/VersionInfoMojo.java | 457 ++-- storm-client/pom.xml | 2 +- .../src/jvm/org/apache/storm/Config.java | 1224 ++++------- .../src/jvm/org/apache/storm/Constants.java | 21 +- .../org/apache/storm/ICredentialsListener.java | 21 +- .../src/jvm/org/apache/storm/ILocalCluster.java | 121 +- .../src/jvm/org/apache/storm/ILocalDRPC.java | 21 +- .../jvm/org/apache/storm/ISubmitterHook.java | 26 +- .../src/jvm/org/apache/storm/LogWriter.java | 68 +- .../jvm/org/apache/storm/StormSubmitter.java | 212 +- .../src/jvm/org/apache/storm/StormTimer.java | 239 +- .../src/jvm/org/apache/storm/Thrift.java | 125 +- .../storm/annotation/InterfaceStability.java | 43 +- .../assignments/ILocalAssignmentsBackend.java | 36 +- .../assignments/InMemoryAssignmentBackend.java | 38 +- .../LocalAssignmentsBackendFactory.java | 27 +- .../storm/blobstore/AtomicOutputStream.java | 24 +- .../org/apache/storm/blobstore/BlobStore.java | 309 ++- .../storm/blobstore/BlobStoreAclHandler.java | 125 +- .../apache/storm/blobstore/BlobStoreFile.java | 38 +- .../apache/storm/blobstore/ClientBlobStore.java | 98 +- .../storm/blobstore/InputStreamWithMeta.java | 20 +- .../org/apache/storm/blobstore/KeyFilter.java | 19 +- .../blobstore/LocalModeClientBlobStore.java | 21 +- .../apache/storm/blobstore/NimbusBlobStore.java | 399 ++-- .../src/jvm/org/apache/storm/bolt/JoinBolt.java | 534 ++--- .../storm/callback/DefaultWatcherCallBack.java | 19 +- .../apache/storm/callback/WatcherCallBack.java | 19 +- .../storm/callback/ZKStateChangedCallback.java | 18 +- .../storm/cluster/ClusterStateContext.java | 26 +- .../storm/cluster/ClusterStateListener.java | 19 +- .../org/apache/storm/cluster/ClusterUtils.java | 112 +- .../apache/storm/cluster/ConnectionState.java | 19 +- .../org/apache/storm/cluster/DaemonType.java | 32 +- .../org/apache/storm/cluster/ExecutorBeat.java | 19 +- .../org/apache/storm/cluster/IStateStorage.java | 155 +- .../storm/cluster/IStormClusterState.java | 110 +- .../storm/cluster/PaceMakerStateStorage.java | 44 +- .../storm/cluster/StateStorageFactory.java | 18 +- .../storm/cluster/StormClusterStateImpl.java | 127 +- .../org/apache/storm/cluster/VersionedData.java | 25 +- .../apache/storm/cluster/ZKStateStorage.java | 53 +- .../storm/cluster/ZKStateStorageFactory.java | 3 - .../storm/container/cgroup/CgroupCenter.java | 30 +- .../storm/container/cgroup/CgroupCommon.java | 80 +- .../container/cgroup/CgroupCommonOperation.java | 39 +- .../container/cgroup/CgroupCoreFactory.java | 66 +- .../storm/container/cgroup/CgroupOperation.java | 23 +- .../storm/container/cgroup/CgroupUtils.java | 26 +- .../apache/storm/container/cgroup/Device.java | 19 +- .../storm/container/cgroup/Hierarchy.java | 19 +- .../storm/container/cgroup/SubSystem.java | 25 +- .../storm/container/cgroup/SubSystemType.java | 19 +- .../storm/container/cgroup/SystemOperation.java | 39 +- .../storm/container/cgroup/core/BlkioCore.java | 34 +- .../storm/container/cgroup/core/CgroupCore.java | 19 +- .../storm/container/cgroup/core/CpuCore.java | 48 +- .../container/cgroup/core/CpuacctCore.java | 24 +- .../storm/container/cgroup/core/CpusetCore.java | 160 +- .../container/cgroup/core/DevicesCore.java | 117 +- .../container/cgroup/core/FreezerCore.java | 39 +- .../storm/container/cgroup/core/MemoryCore.java | 168 +- .../storm/container/cgroup/core/NetClsCore.java | 24 +- .../container/cgroup/core/NetPrioCore.java | 24 +- .../storm/coordination/BatchBoltExecutor.java | 50 +- .../coordination/BatchOutputCollector.java | 12 +- .../coordination/BatchOutputCollectorImpl.java | 29 +- .../coordination/BatchSubtopologyBuilder.java | 165 +- .../storm/coordination/CoordinatedBolt.java | 475 ++-- .../apache/storm/coordination/IBatchBolt.java | 25 +- .../src/jvm/org/apache/storm/daemon/Acker.java | 62 +- .../org/apache/storm/daemon/DaemonCommon.java | 19 +- .../org/apache/storm/daemon/GrouperFactory.java | 88 +- .../org/apache/storm/daemon/Shutdownable.java | 19 +- .../org/apache/storm/daemon/StormCommon.java | 253 ++- .../src/jvm/org/apache/storm/daemon/Task.java | 70 +- .../daemon/metrics/BuiltinBoltMetrics.java | 19 +- .../storm/daemon/metrics/BuiltinMetrics.java | 19 +- .../daemon/metrics/BuiltinMetricsUtil.java | 31 +- .../daemon/metrics/BuiltinSpoutMetrics.java | 19 +- .../daemon/metrics/ClientMetricsUtils.java | 18 +- .../daemon/metrics/ErrorReportingMetrics.java | 18 +- .../daemon/metrics/SpoutThrottlingMetrics.java | 18 +- .../storm/daemon/supervisor/AdvancedFSOps.java | 258 ++- .../supervisor/ClientSupervisorUtils.java | 70 +- .../daemon/supervisor/ExitCodeCallback.java | 24 +- .../storm/daemon/supervisor/IAdvancedFSOps.java | 56 +- .../daemon/worker/BackPressureTracker.java | 10 +- .../storm/daemon/worker/LogConfigManager.java | 17 +- .../org/apache/storm/daemon/worker/Worker.java | 176 +- .../apache/storm/daemon/worker/WorkerState.java | 397 ++-- .../storm/daemon/worker/WorkerTransfer.java | 6 +- .../dependency/DependencyBlobStoreUtils.java | 3 +- .../dependency/DependencyPropertiesParser.java | 24 +- .../storm/dependency/DependencyUploader.java | 32 +- .../dependency/FileNotAvailableException.java | 18 +- .../storm/drpc/DRPCInvocationsClient.java | 50 +- .../jvm/org/apache/storm/drpc/DRPCSpout.java | 152 +- .../jvm/org/apache/storm/drpc/JoinResult.java | 37 +- .../org/apache/storm/drpc/KeyedFairBolt.java | 35 +- .../storm/drpc/LinearDRPCInputDeclarer.java | 32 +- .../storm/drpc/LinearDRPCTopologyBuilder.java | 133 +- .../org/apache/storm/drpc/PrepareRequest.java | 24 +- .../org/apache/storm/drpc/ReturnResults.java | 56 +- .../jvm/org/apache/storm/executor/Executor.java | 99 +- .../apache/storm/executor/ExecutorShutdown.java | 33 +- .../apache/storm/executor/ExecutorTransfer.java | 49 +- .../apache/storm/executor/IRunningExecutor.java | 21 +- .../apache/storm/executor/LocalExecutor.java | 25 +- .../org/apache/storm/executor/TupleInfo.java | 26 +- .../storm/executor/bolt/BoltExecutor.java | 50 +- .../executor/bolt/BoltOutputCollectorImpl.java | 38 +- .../storm/executor/error/IReportError.java | 19 +- .../storm/executor/error/ReportError.java | 33 +- .../storm/executor/error/ReportErrorAndDie.java | 23 +- .../storm/executor/spout/SpoutExecutor.java | 43 +- .../spout/SpoutOutputCollectorImpl.java | 39 +- .../storm/grouping/CustomStreamGrouping.java | 48 +- .../src/jvm/org/apache/storm/grouping/Load.java | 31 +- .../grouping/LoadAwareCustomStreamGrouping.java | 21 +- .../grouping/LoadAwareShuffleGrouping.java | 87 +- .../org/apache/storm/grouping/LoadMapping.java | 41 +- .../storm/grouping/PartialKeyGrouping.java | 57 +- .../apache/storm/grouping/ShuffleGrouping.java | 30 +- .../org/apache/storm/hooks/BaseTaskHook.java | 23 +- .../org/apache/storm/hooks/BaseWorkerHook.java | 29 +- .../jvm/org/apache/storm/hooks/ITaskHook.java | 34 +- .../jvm/org/apache/storm/hooks/IWorkerHook.java | 30 +- .../storm/hooks/SubmitterHookException.java | 1 + .../apache/storm/hooks/info/BoltAckInfo.java | 21 +- .../storm/hooks/info/BoltExecuteInfo.java | 21 +- .../apache/storm/hooks/info/BoltFailInfo.java | 21 +- .../org/apache/storm/hooks/info/EmitInfo.java | 26 +- .../apache/storm/hooks/info/SpoutAckInfo.java | 21 +- .../apache/storm/hooks/info/SpoutFailInfo.java | 21 +- .../storm/lambda/LambdaBiConsumerBolt.java | 23 +- .../apache/storm/lambda/LambdaConsumerBolt.java | 19 +- .../org/apache/storm/lambda/LambdaSpout.java | 22 +- .../storm/lambda/SerializableBiConsumer.java | 22 +- .../storm/lambda/SerializableCallable.java | 18 +- .../storm/lambda/SerializableConsumer.java | 22 +- .../storm/lambda/SerializableSupplier.java | 22 +- .../storm/messaging/ConnectionWithStatus.java | 59 +- .../DeserializingConnectionCallback.java | 41 +- .../org/apache/storm/messaging/IConnection.java | 41 +- .../storm/messaging/IConnectionCallback.java | 20 +- .../org/apache/storm/messaging/IContext.java | 47 +- .../org/apache/storm/messaging/TaskMessage.java | 37 +- .../storm/messaging/TransportFactory.java | 37 +- .../apache/storm/messaging/local/Context.java | 138 +- .../messaging/netty/BackPressureStatus.java | 27 +- .../apache/storm/messaging/netty/Client.java | 158 +- .../apache/storm/messaging/netty/Context.java | 49 +- .../storm/messaging/netty/ControlMessage.java | 57 +- .../messaging/netty/INettySerializable.java | 20 +- .../storm/messaging/netty/ISaslClient.java | 23 +- .../storm/messaging/netty/ISaslServer.java | 21 +- .../apache/storm/messaging/netty/IServer.java | 21 +- .../netty/KerberosSaslClientHandler.java | 31 +- .../netty/KerberosSaslNettyClient.java | 102 +- .../netty/KerberosSaslNettyClientState.java | 19 +- .../netty/KerberosSaslNettyServer.java | 135 +- .../netty/KerberosSaslNettyServerState.java | 27 +- .../netty/KerberosSaslServerHandler.java | 40 +- .../org/apache/storm/messaging/netty/Login.java | 137 +- .../storm/messaging/netty/MessageBatch.java | 56 +- .../storm/messaging/netty/MessageBuffer.java | 27 +- .../storm/messaging/netty/MessageDecoder.java | 53 +- .../storm/messaging/netty/MessageEncoder.java | 31 +- .../netty/NettyRenameThreadFactory.java | 37 +- .../netty/NettyUncaughtExceptionHandler.java | 20 +- .../storm/messaging/netty/SaslMessageToken.java | 79 +- .../storm/messaging/netty/SaslNettyClient.java | 68 +- .../messaging/netty/SaslNettyClientState.java | 29 +- .../storm/messaging/netty/SaslNettyServer.java | 73 +- .../messaging/netty/SaslNettyServerState.java | 27 +- .../messaging/netty/SaslStormClientHandler.java | 63 +- .../netty/SaslStormServerAuthorizeHandler.java | 105 +- .../messaging/netty/SaslStormServerHandler.java | 74 +- .../apache/storm/messaging/netty/SaslUtils.java | 34 +- .../apache/storm/messaging/netty/Server.java | 102 +- .../messaging/netty/StormClientHandler.java | 58 +- .../netty/StormClientPipelineFactory.java | 30 +- .../messaging/netty/StormServerHandler.java | 66 +- .../netty/StormServerPipelineFactory.java | 30 +- .../apache/storm/metric/EventLoggerBolt.java | 33 +- .../storm/metric/FileBasedEventLogger.java | 9 +- .../org/apache/storm/metric/IEventLogger.java | 51 +- .../storm/metric/LoggingMetricsConsumer.java | 57 +- .../storm/metric/MetricsConsumerBolt.java | 48 +- .../jvm/org/apache/storm/metric/SystemBolt.java | 138 +- .../storm/metric/api/AssignableMetric.java | 19 +- .../apache/storm/metric/api/CombinedMetric.java | 21 +- .../apache/storm/metric/api/CountMetric.java | 21 +- .../org/apache/storm/metric/api/ICombiner.java | 20 +- .../org/apache/storm/metric/api/IMetric.java | 26 +- .../storm/metric/api/IMetricsConsumer.java | 79 +- .../storm/metric/api/IMetricsRegistrant.java | 18 +- .../org/apache/storm/metric/api/IReducer.java | 21 +- .../storm/metric/api/IStatefulObject.java | 19 +- .../apache/storm/metric/api/MeanReducer.java | 14 +- .../storm/metric/api/MultiCountMetric.java | 26 +- .../storm/metric/api/MultiReducedMetric.java | 28 +- .../apache/storm/metric/api/ReducedMetric.java | 19 +- .../apache/storm/metric/api/StateMetric.java | 19 +- .../metric/api/rpc/AssignableShellMetric.java | 19 +- .../metric/api/rpc/CombinedShellMetric.java | 19 +- .../storm/metric/api/rpc/CountShellMetric.java | 21 +- .../storm/metric/api/rpc/IShellMetric.java | 19 +- .../metric/api/rpc/ReducedShellMetric.java | 19 +- .../apache/storm/metric/cgroup/CGroupCpu.java | 28 +- .../storm/metric/cgroup/CGroupCpuGuarantee.java | 24 +- .../storm/metric/cgroup/CGroupMemoryLimit.java | 24 +- .../storm/metric/cgroup/CGroupMemoryUsage.java | 20 +- .../storm/metric/cgroup/CGroupMetricsBase.java | 38 +- .../storm/metric/filter/FilterByMetricName.java | 26 +- .../storm/metric/filter/MetricsFilter.java | 22 +- .../metric/internal/CountStatAndMetric.java | 67 +- .../metric/internal/LatencyStatAndMetric.java | 62 +- .../storm/metric/internal/MetricStatTimer.java | 19 +- .../internal/MultiCountStatAndMetric.java | 43 +- .../internal/MultiLatencyStatAndMetric.java | 44 +- .../storm/metric/internal/RateTracker.java | 54 +- .../storm/metric/util/DataPointExpander.java | 94 +- .../org/apache/storm/metrics2/JcMetrics.java | 18 +- .../org/apache/storm/metrics2/SimpleGauge.java | 18 +- .../storm/metrics2/StormMetricRegistry.java | 38 +- .../org/apache/storm/metrics2/TaskMetrics.java | 20 +- .../storm/metrics2/filters/RegexFilter.java | 19 +- .../metrics2/filters/StormMetricsFilter.java | 20 +- .../reporters/ConsoleStormReporter.java | 18 +- .../metrics2/reporters/CsvStormReporter.java | 66 +- .../reporters/GangliaStormReporter.java | 80 +- .../reporters/GraphiteStormReporter.java | 53 +- .../metrics2/reporters/JmxStormReporter.java | 30 +- .../reporters/ScheduledStormReporter.java | 61 +- .../storm/metrics2/reporters/StormReporter.java | 19 +- .../jvm/org/apache/storm/multilang/BoltMsg.java | 31 +- .../org/apache/storm/multilang/ISerializer.java | 34 +- .../apache/storm/multilang/JsonSerializer.java | 44 +- .../storm/multilang/NoOutputException.java | 22 +- .../org/apache/storm/multilang/ShellMsg.java | 106 +- .../org/apache/storm/multilang/SpoutMsg.java | 31 +- .../AbstractDNSToSwitchMapping.java | 52 +- .../networktopography/DNSToSwitchMapping.java | 42 +- .../DefaultRackDNSToSwitchMapping.java | 24 +- .../jvm/org/apache/storm/nimbus/NimbusInfo.java | 65 +- .../apache/storm/pacemaker/PacemakerClient.java | 125 +- .../storm/pacemaker/PacemakerClientHandler.java | 42 +- .../storm/pacemaker/PacemakerClientPool.java | 43 +- .../pacemaker/PacemakerConnectionException.java | 19 +- .../storm/pacemaker/codec/ThriftDecoder.java | 37 +- .../storm/pacemaker/codec/ThriftEncoder.java | 67 +- .../pacemaker/codec/ThriftNettyClientCodec.java | 53 +- .../org/apache/storm/policy/IWaitStrategy.java | 19 +- .../apache/storm/policy/WaitStrategyPark.java | 22 +- .../storm/policy/WaitStrategyProgressive.java | 31 +- .../org/apache/storm/scheduler/WorkerSlot.java | 30 +- .../storm/security/INimbusCredentialPlugin.java | 46 +- .../apache/storm/security/auth/AuthUtils.java | 145 +- .../org/apache/storm/security/auth/AutoSSL.java | 134 +- .../auth/DefaultHttpCredentialsPlugin.java | 39 +- .../security/auth/DefaultPrincipalToLocal.java | 30 +- .../storm/security/auth/FixedGroupsMapping.java | 25 +- .../apache/storm/security/auth/IAuthorizer.java | 42 +- .../storm/security/auth/IAutoCredentials.java | 37 +- .../security/auth/ICredentialsRenewer.java | 39 +- .../auth/IGroupMappingServiceProvider.java | 26 +- .../security/auth/IHttpCredentialsPlugin.java | 24 +- .../storm/security/auth/IPrincipalToLocal.java | 27 +- .../storm/security/auth/ITransportPlugin.java | 41 +- .../security/auth/KerberosPrincipalToLocal.java | 32 +- .../storm/security/auth/NimbusPrincipal.java | 26 +- .../apache/storm/security/auth/ReqContext.java | 105 +- .../security/auth/ShellBasedGroupsMapping.java | 48 +- .../security/auth/SimpleTransportPlugin.java | 90 +- .../security/auth/SingleUserPrincipal.java | 18 +- .../storm/security/auth/TBackoffConnect.java | 29 +- .../storm/security/auth/ThriftClient.java | 60 +- .../security/auth/ThriftConnectionType.java | 46 +- .../storm/security/auth/ThriftServer.java | 31 +- .../auth/authorizer/DRPCAuthorizerBase.java | 38 +- .../authorizer/DRPCSimpleACLAuthorizer.java | 105 +- .../auth/authorizer/DenyAuthorizer.java | 30 +- .../authorizer/ImpersonationAuthorizer.java | 76 +- .../auth/authorizer/NoopAuthorizer.java | 30 +- .../auth/authorizer/SimpleACLAuthorizer.java | 129 +- .../authorizer/SimpleWhitelistAuthorizer.java | 36 +- .../SupervisorSimpleACLAuthorizer.java | 41 +- .../auth/digest/DigestSaslTransportPlugin.java | 42 +- .../auth/digest/JassPasswordProvider.java | 30 +- .../storm/security/auth/kerberos/AutoTGT.java | 162 +- .../auth/kerberos/AutoTGTKrb5LoginModule.java | 29 +- .../kerberos/AutoTGTKrb5LoginModuleTest.java | 20 +- .../auth/kerberos/ClientCallbackHandler.java | 68 +- .../kerberos/KerberosSaslTransportPlugin.java | 223 +- .../security/auth/kerberos/NoOpTTrasport.java | 19 +- .../auth/kerberos/ServerCallbackHandler.java | 43 +- .../auth/plain/PlainClientCallbackHandler.java | 23 +- .../auth/plain/PlainSaslTransportPlugin.java | 43 +- .../security/auth/plain/SaslPlainServer.java | 249 ++- .../security/auth/sasl/PasswordProvider.java | 35 +- .../security/auth/sasl/SaslTransportPlugin.java | 35 +- .../sasl/SimpleSaslClientCallbackHandler.java | 21 +- .../sasl/SimpleSaslServerCallbackHandler.java | 40 +- .../auth/workertoken/WorkerTokenAuthorizer.java | 71 +- .../WorkerTokenClientCallbackHandler.java | 50 +- .../auth/workertoken/WorkerTokenSigner.java | 6 +- .../serialization/BlowfishTupleSerializer.java | 66 +- .../storm/serialization/DefaultKryoFactory.java | 65 +- .../DefaultSerializationDelegate.java | 31 +- .../GzipBridgeSerializationDelegate.java | 34 +- .../GzipBridgeThriftSerializationDelegate.java | 34 +- .../GzipSerializationDelegate.java | 31 +- .../GzipThriftSerializationDelegate.java | 4 +- .../storm/serialization/IKryoDecorator.java | 20 +- .../storm/serialization/IKryoFactory.java | 37 +- .../storm/serialization/ITupleDeserializer.java | 21 +- .../storm/serialization/ITupleSerializer.java | 21 +- .../serialization/KryoTupleDeserializer.java | 31 +- .../serialization/KryoTupleSerializer.java | 47 +- .../serialization/KryoValuesDeserializer.java | 36 +- .../serialization/KryoValuesSerializer.java | 31 +- .../serialization/SerializableSerializer.java | 25 +- .../serialization/SerializationDelegate.java | 19 +- .../serialization/SerializationFactory.java | 171 +- .../serialization/SerializationRegister.java | 9 +- .../ThriftSerializationDelegate.java | 26 +- .../types/ArrayListSerializer.java | 21 +- .../serialization/types/HashMapSerializer.java | 19 +- .../serialization/types/HashSetSerializer.java | 21 +- .../types/ListDelegateSerializer.java | 23 +- .../org/apache/storm/spout/CheckPointState.java | 117 +- .../org/apache/storm/spout/CheckpointSpout.java | 28 +- .../storm/spout/IMultiSchemableSpout.java | 24 +- .../org/apache/storm/spout/ISchemableSpout.java | 24 +- .../src/jvm/org/apache/storm/spout/ISpout.java | 105 +- .../storm/spout/ISpoutOutputCollector.java | 35 +- .../jvm/org/apache/storm/spout/MultiScheme.java | 27 +- .../org/apache/storm/spout/RawMultiScheme.java | 18 +- .../jvm/org/apache/storm/spout/RawScheme.java | 8 +- .../src/jvm/org/apache/storm/spout/Scheme.java | 21 +- .../apache/storm/spout/SchemeAsMultiScheme.java | 49 +- .../jvm/org/apache/storm/spout/ShellSpout.java | 80 +- .../storm/spout/SpoutOutputCollector.java | 102 +- .../storm/state/BaseBinaryStateIterator.java | 23 +- .../apache/storm/state/BaseStateIterator.java | 23 +- .../apache/storm/state/DefaultStateEncoder.java | 24 +- .../storm/state/DefaultStateSerializer.java | 38 +- .../jvm/org/apache/storm/state/IStateSpout.java | 24 +- .../storm/state/IStateSpoutOutputCollector.java | 19 +- .../apache/storm/state/ISubscribedState.java | 20 +- .../state/ISynchronizeOutputCollector.java | 21 +- .../storm/state/InMemoryKeyValueState.java | 71 +- .../state/InMemoryKeyValueStateProvider.java | 22 +- .../org/apache/storm/state/KeyValueState.java | 22 +- .../jvm/org/apache/storm/state/Serializer.java | 22 +- .../src/jvm/org/apache/storm/state/State.java | 29 +- .../org/apache/storm/state/StateEncoder.java | 18 +- .../org/apache/storm/state/StateFactory.java | 30 +- .../org/apache/storm/state/StateProvider.java | 28 +- .../storm/state/StateSpoutOutputCollector.java | 19 +- .../storm/state/SynchronizeOutputCollector.java | 19 +- .../apache/storm/stats/BoltExecutorStats.java | 34 +- .../jvm/org/apache/storm/stats/CommonStats.java | 25 +- .../apache/storm/stats/SpoutExecutorStats.java | 24 +- .../jvm/org/apache/storm/stats/StatsUtil.java | 371 ++-- .../src/jvm/org/apache/storm/streams/Edge.java | 19 +- .../org/apache/storm/streams/GroupingInfo.java | 38 +- .../src/jvm/org/apache/storm/streams/Node.java | 72 +- .../src/jvm/org/apache/storm/streams/Pair.java | 57 +- .../org/apache/storm/streams/PairStream.java | 149 +- .../org/apache/storm/streams/PartitionNode.java | 24 +- .../org/apache/storm/streams/ProcessorBolt.java | 24 +- .../storm/streams/ProcessorBoltDelegate.java | 60 +- .../org/apache/storm/streams/ProcessorNode.java | 44 +- .../apache/storm/streams/RefCountedTuple.java | 30 +- .../jvm/org/apache/storm/streams/SinkNode.java | 22 +- .../jvm/org/apache/storm/streams/SpoutNode.java | 21 +- .../storm/streams/StatefulProcessorBolt.java | 30 +- .../jvm/org/apache/storm/streams/Stream.java | 123 +- .../org/apache/storm/streams/StreamBolt.java | 22 +- .../org/apache/storm/streams/StreamBuilder.java | 82 +- .../org/apache/storm/streams/StreamState.java | 22 +- .../org/apache/storm/streams/StreamUtil.java | 24 +- .../storm/streams/StreamsEdgeFactory.java | 22 +- .../org/apache/storm/streams/UniqueIdGen.java | 21 +- .../org/apache/storm/streams/WindowNode.java | 21 +- .../storm/streams/WindowedProcessorBolt.java | 26 +- .../storm/streams/operations/BiFunction.java | 19 +- .../streams/operations/CombinerAggregator.java | 85 +- .../storm/streams/operations/Consumer.java | 19 +- .../streams/operations/FlatMapFunction.java | 19 +- .../storm/streams/operations/Function.java | 19 +- .../streams/operations/IdentityFunction.java | 19 +- .../storm/streams/operations/Operation.java | 19 +- .../streams/operations/PairFlatMapFunction.java | 19 +- .../storm/streams/operations/PairFunction.java | 21 +- .../streams/operations/PairValueJoiner.java | 19 +- .../storm/streams/operations/Predicate.java | 19 +- .../storm/streams/operations/PrintConsumer.java | 19 +- .../storm/streams/operations/Reducer.java | 22 +- .../storm/streams/operations/StateUpdater.java | 54 +- .../storm/streams/operations/ValueJoiner.java | 19 +- .../streams/operations/aggregators/Count.java | 19 +- .../streams/operations/aggregators/LongSum.java | 19 +- .../operations/mappers/PairValueMapper.java | 22 +- .../operations/mappers/TupleValueMapper.java | 22 +- .../operations/mappers/TupleValueMappers.java | 128 +- .../streams/operations/mappers/ValueMapper.java | 22 +- .../operations/mappers/ValuesMapper.java | 25 +- .../processors/AggregateByKeyProcessor.java | 33 +- .../streams/processors/AggregateProcessor.java | 27 +- .../storm/streams/processors/BaseProcessor.java | 45 +- .../streams/processors/BatchProcessor.java | 22 +- .../streams/processors/BranchProcessor.java | 22 +- .../processors/ChainedProcessorContext.java | 22 +- .../processors/CoGroupByKeyProcessor.java | 23 +- .../processors/EmittingProcessorContext.java | 37 +- .../streams/processors/FilterProcessor.java | 19 +- .../streams/processors/FlatMapProcessor.java | 19 +- .../processors/FlatMapValuesProcessor.java | 19 +- .../streams/processors/ForEachProcessor.java | 19 +- .../processors/ForwardingProcessorContext.java | 25 +- .../storm/streams/processors/JoinProcessor.java | 36 +- .../storm/streams/processors/MapProcessor.java | 19 +- .../streams/processors/MapValuesProcessor.java | 19 +- .../MergeAggregateByKeyProcessor.java | 24 +- .../processors/MergeAggregateProcessor.java | 19 +- .../storm/streams/processors/PeekProcessor.java | 19 +- .../storm/streams/processors/Processor.java | 29 +- .../streams/processors/ProcessorContext.java | 28 +- .../processors/ReduceByKeyProcessor.java | 24 +- .../streams/processors/ReduceProcessor.java | 19 +- .../streams/processors/StateQueryProcessor.java | 19 +- .../streams/processors/StatefulProcessor.java | 22 +- .../processors/UpdateStateByKeyProcessor.java | 19 +- .../org/apache/storm/streams/tuple/Tuple10.java | 63 +- .../org/apache/storm/streams/tuple/Tuple3.java | 35 +- .../org/apache/storm/streams/tuple/Tuple4.java | 39 +- .../org/apache/storm/streams/tuple/Tuple5.java | 43 +- .../org/apache/storm/streams/tuple/Tuple6.java | 47 +- .../org/apache/storm/streams/tuple/Tuple7.java | 51 +- .../org/apache/storm/streams/tuple/Tuple8.java | 55 +- .../org/apache/storm/streams/tuple/Tuple9.java | 59 +- .../storm/streams/windowing/BaseWindow.java | 33 +- .../storm/streams/windowing/SlidingWindows.java | 84 +- .../streams/windowing/TumblingWindows.java | 68 +- .../apache/storm/streams/windowing/Window.java | 32 +- .../storm/task/GeneralTopologyContext.java | 70 +- .../src/jvm/org/apache/storm/task/IBolt.java | 86 +- .../org/apache/storm/task/IErrorReporter.java | 19 +- .../org/apache/storm/task/IMetricsContext.java | 23 +- .../org/apache/storm/task/IOutputCollector.java | 29 +- .../org/apache/storm/task/OutputCollector.java | 164 +- .../jvm/org/apache/storm/task/ShellBolt.java | 95 +- .../org/apache/storm/task/TopologyContext.java | 188 +- .../storm/task/WorkerTopologyContext.java | 110 +- .../apache/storm/testing/AckFailDelegate.java | 20 +- .../apache/storm/testing/AckFailMapTracker.java | 39 +- .../org/apache/storm/testing/AckTracker.java | 31 +- .../AlternateRackDNSToSwitchMapping.java | 79 +- .../apache/storm/testing/BatchNumberList.java | 53 +- .../apache/storm/testing/BatchProcessWord.java | 21 +- .../org/apache/storm/testing/BatchRepeatA.java | 33 +- .../org/apache/storm/testing/BoltTracker.java | 23 +- .../apache/storm/testing/CompletableSpout.java | 21 +- .../apache/storm/testing/CountingBatchBolt.java | 31 +- .../storm/testing/CountingCommitBolt.java | 29 +- .../org/apache/storm/testing/FeederSpout.java | 40 +- .../org/apache/storm/testing/FixedTuple.java | 22 +- .../apache/storm/testing/FixedTupleSpout.java | 108 +- .../testing/ForwardingMetricsConsumer.java | 61 +- .../org/apache/storm/testing/IdentityBolt.java | 23 +- .../apache/storm/testing/IntegrationTest.java | 14 +- .../storm/testing/KeyedCountingBatchBolt.java | 34 +- .../testing/KeyedCountingCommitterBolt.java | 19 +- .../storm/testing/KeyedSummingBatchBolt.java | 33 +- .../storm/testing/MemoryTransactionalSpout.java | 185 +- .../testing/MemoryTransactionalSpoutMeta.java | 27 +- .../apache/storm/testing/MkClusterParam.java | 112 +- .../org/apache/storm/testing/MkTupleParam.java | 87 +- .../org/apache/storm/testing/MockedSources.java | 42 +- .../jvm/org/apache/storm/testing/NGrouping.java | 37 +- .../storm/testing/NonRichBoltTracker.java | 23 +- .../testing/OpaqueMemoryTransactionalSpout.java | 163 +- .../apache/storm/testing/PrepareBatchBolt.java | 30 +- .../storm/testing/PythonShellMetricsBolt.java | 30 +- .../storm/testing/PythonShellMetricsSpout.java | 34 +- .../testing/SingleUserSimpleTransport.java | 45 +- .../org/apache/storm/testing/SpoutTracker.java | 100 +- .../storm/testing/TestAggregatesCounter.java | 34 +- .../org/apache/storm/testing/TestConfBolt.java | 31 +- .../apache/storm/testing/TestEventLogSpout.java | 114 +- .../storm/testing/TestEventOrderCheckBolt.java | 35 +- .../apache/storm/testing/TestGlobalCount.java | 30 +- .../apache/storm/testing/TestKryoDecorator.java | 24 +- .../apache/storm/testing/TestPlannerBolt.java | 31 +- .../apache/storm/testing/TestPlannerSpout.java | 56 +- .../org/apache/storm/testing/TestSerObject.java | 27 +- .../storm/testing/TestWordBytesCounter.java | 21 +- .../apache/storm/testing/TestWordCounter.java | 42 +- .../org/apache/storm/testing/TestWordSpout.java | 48 +- .../jvm/org/apache/storm/testing/TmpPath.java | 44 +- .../apache/storm/testing/TupleCaptureBolt.java | 37 +- .../topology/BaseConfigurationDeclarer.java | 40 +- .../topology/BaseStatefulBoltExecutor.java | 57 +- .../storm/topology/BasicBoltExecutor.java | 31 +- .../storm/topology/BasicOutputCollector.java | 33 +- .../org/apache/storm/topology/BoltDeclarer.java | 22 +- .../topology/CheckpointTupleForwarder.java | 49 +- .../ComponentConfigurationDeclarer.java | 26 +- .../storm/topology/ConfigurableTopology.java | 94 +- .../apache/storm/topology/FailedException.java | 23 +- .../org/apache/storm/topology/IBasicBolt.java | 25 +- .../storm/topology/IBasicOutputCollector.java | 26 +- .../org/apache/storm/topology/IComponent.java | 28 +- .../org/apache/storm/topology/IRichBolt.java | 24 +- .../org/apache/storm/topology/IRichSpout.java | 24 +- .../apache/storm/topology/IRichStateSpout.java | 19 +- .../apache/storm/topology/IStatefulBolt.java | 30 +- .../storm/topology/IStatefulComponent.java | 34 +- .../storm/topology/IStatefulWindowedBolt.java | 21 +- .../apache/storm/topology/IWindowedBolt.java | 30 +- .../apache/storm/topology/InputDeclarer.java | 77 +- .../storm/topology/OutputFieldsDeclarer.java | 23 +- .../storm/topology/OutputFieldsGetter.java | 25 +- .../PersistentWindowedBoltExecutor.java | 38 +- .../storm/topology/ReportedFailedException.java | 23 +- .../apache/storm/topology/ResourceDeclarer.java | 37 +- .../storm/topology/SharedOffHeapWithinNode.java | 22 +- .../topology/SharedOffHeapWithinWorker.java | 22 +- .../org/apache/storm/topology/SharedOnHeap.java | 22 +- .../apache/storm/topology/SpoutDeclarer.java | 21 +- .../storm/topology/StatefulBoltExecutor.java | 37 +- .../topology/StatefulWindowedBoltExecutor.java | 80 +- .../apache/storm/topology/TopologyBuilder.java | 379 ++-- .../topology/TupleFieldTimestampExtractor.java | 31 +- .../storm/topology/WindowedBoltExecutor.java | 75 +- .../storm/topology/base/BaseBasicBolt.java | 23 +- .../storm/topology/base/BaseBatchBolt.java | 21 +- .../storm/topology/base/BaseComponent.java | 23 +- ...BaseOpaquePartitionedTransactionalSpout.java | 21 +- .../base/BasePartitionedTransactionalSpout.java | 19 +- .../storm/topology/base/BaseRichBolt.java | 21 +- .../storm/topology/base/BaseRichSpout.java | 19 +- .../storm/topology/base/BaseStatefulBolt.java | 22 +- .../topology/base/BaseStatefulWindowedBolt.java | 31 +- .../base/BaseTickTupleAwareRichBolt.java | 8 +- .../topology/base/BaseTransactionalBolt.java | 21 +- .../topology/base/BaseTransactionalSpout.java | 19 +- .../storm/topology/base/BaseWindowedBolt.java | 325 ++- .../apache/storm/transactional/ICommitter.java | 25 +- .../ICommitterTransactionalSpout.java | 29 +- .../transactional/ITransactionalSpout.java | 95 +- .../storm/transactional/TransactionAttempt.java | 37 +- .../TransactionalSpoutBatchExecutor.java | 39 +- .../TransactionalSpoutCoordinator.java | 139 +- .../TransactionalTopologyBuilder.java | 265 ++- .../IOpaquePartitionedTransactionalSpout.java | 48 +- .../IPartitionedTransactionalSpout.java | 63 +- ...uePartitionedTransactionalSpoutExecutor.java | 118 +- .../PartitionedTransactionalSpoutExecutor.java | 114 +- .../state/RotatingTransactionalState.java | 102 +- .../state/TestTransactionalState.java | 31 +- .../transactional/state/TransactionalState.java | 108 +- .../apache/storm/trident/JoinOutFieldsMode.java | 29 +- .../jvm/org/apache/storm/trident/JoinType.java | 21 +- .../jvm/org/apache/storm/trident/Stream.java | 387 ++-- .../org/apache/storm/trident/TridentState.java | 19 +- .../apache/storm/trident/TridentTopology.java | 1463 ++++++------- .../trident/drpc/ReturnResultsReducer.java | 78 +- .../fluent/ChainedAggregatorDeclarer.java | 119 +- .../fluent/ChainedFullAggregatorDeclarer.java | 26 +- .../ChainedPartitionAggregatorDeclarer.java | 28 +- .../trident/fluent/GlobalAggregationScheme.java | 20 +- .../storm/trident/fluent/GroupedStream.java | 79 +- .../trident/fluent/IAggregatableStream.java | 25 +- .../fluent/IChainedAggregatorDeclarer.java | 19 +- .../storm/trident/fluent/UniqueIdGen.java | 21 +- .../storm/trident/graph/GraphGrouper.java | 89 +- .../org/apache/storm/trident/graph/Group.java | 99 +- .../storm/trident/operation/Aggregator.java | 21 +- .../storm/trident/operation/Assembly.java | 25 +- .../storm/trident/operation/BaseAggregator.java | 21 +- .../storm/trident/operation/BaseFilter.java | 21 +- .../storm/trident/operation/BaseFunction.java | 21 +- .../trident/operation/BaseMultiReducer.java | 21 +- .../storm/trident/operation/BaseOperation.java | 29 +- .../trident/operation/CombinerAggregator.java | 21 +- .../storm/trident/operation/Consumer.java | 25 +- .../operation/DefaultResourceDeclarer.java | 34 +- .../storm/trident/operation/EachOperation.java | 21 +- .../apache/storm/trident/operation/Filter.java | 31 +- .../trident/operation/FlatMapFunction.java | 23 +- .../storm/trident/operation/Function.java | 86 +- .../trident/operation/GroupedMultiReducer.java | 23 +- .../trident/operation/ITridentResource.java | 26 +- .../storm/trident/operation/MapFunction.java | 22 +- .../storm/trident/operation/MultiReducer.java | 23 +- .../storm/trident/operation/Operation.java | 35 +- .../OperationAwareFlatMapFunction.java | 19 +- .../operation/OperationAwareMapFunction.java | 19 +- .../trident/operation/ReducerAggregator.java | 20 +- .../trident/operation/TridentCollector.java | 33 +- .../operation/TridentMultiReducerContext.java | 29 +- .../operation/TridentOperationContext.java | 37 +- .../operation/builtin/ComparisonAggregator.java | 41 +- .../storm/trident/operation/builtin/Count.java | 21 +- .../storm/trident/operation/builtin/Debug.java | 27 +- .../storm/trident/operation/builtin/Equals.java | 27 +- .../trident/operation/builtin/FilterNull.java | 26 +- .../storm/trident/operation/builtin/FirstN.java | 65 +- .../storm/trident/operation/builtin/MapGet.java | 27 +- .../storm/trident/operation/builtin/Max.java | 25 +- .../operation/builtin/MaxWithComparator.java | 31 +- .../storm/trident/operation/builtin/Min.java | 25 +- .../operation/builtin/MinWithComparator.java | 29 +- .../storm/trident/operation/builtin/Negate.java | 47 +- .../trident/operation/builtin/SnapshotGet.java | 21 +- .../storm/trident/operation/builtin/Sum.java | 40 +- .../operation/builtin/TupleCollectionGet.java | 23 +- .../operation/impl/CaptureCollector.java | 25 +- .../operation/impl/ChainedAggregatorImpl.java | 72 +- .../trident/operation/impl/ChainedResult.java | 35 +- .../operation/impl/CombinerAggStateUpdater.java | 31 +- .../impl/CombinerAggregatorCombineImpl.java | 41 +- .../impl/CombinerAggregatorInitImpl.java | 27 +- .../operation/impl/ConsumerExecutor.java | 19 +- .../trident/operation/impl/FilterExecutor.java | 25 +- .../operation/impl/FlatMapFunctionExecutor.java | 22 +- .../operation/impl/GlobalBatchToPartition.java | 21 +- .../trident/operation/impl/GroupCollector.java | 27 +- .../operation/impl/GroupedAggregator.java | 37 +- .../impl/GroupedMultiReducerExecutor.java | 39 +- .../operation/impl/IdentityMultiReducer.java | 21 +- .../impl/IndexHashBatchToPartition.java | 21 +- .../storm/trident/operation/impl/JoinState.java | 24 +- .../operation/impl/JoinerMultiReducer.java | 59 +- .../operation/impl/MapFunctionExecutor.java | 23 +- ...PreservingFieldsOrderJoinerMultiReducer.java | 38 +- .../operation/impl/ReducerAggStateUpdater.java | 29 +- .../operation/impl/ReducerAggregatorImpl.java | 39 +- .../storm/trident/operation/impl/Result.java | 21 +- .../operation/impl/SingleEmitAggregator.java | 68 +- .../trident/operation/impl/TrueFilter.java | 21 +- .../storm/trident/partition/GlobalGrouping.java | 27 +- .../trident/partition/IdentityGrouping.java | 35 +- .../trident/partition/IndexHashGrouping.java | 45 +- .../storm/trident/planner/BridgeReceiver.java | 23 +- .../org/apache/storm/trident/planner/Node.java | 26 +- .../storm/trident/planner/NodeStateInfo.java | 21 +- .../storm/trident/planner/PartitionNode.java | 27 +- .../storm/trident/planner/ProcessorContext.java | 21 +- .../storm/trident/planner/ProcessorNode.java | 23 +- .../apache/storm/trident/planner/SpoutNode.java | 31 +- .../storm/trident/planner/SubtopologyBolt.java | 110 +- .../storm/trident/planner/TridentProcessor.java | 30 +- .../storm/trident/planner/TupleReceiver.java | 20 +- .../planner/processor/AggregateProcessor.java | 31 +- .../planner/processor/AppendCollector.java | 31 +- .../planner/processor/EachProcessor.java | 33 +- .../planner/processor/FreshCollector.java | 33 +- .../trident/planner/processor/MapProcessor.java | 30 +- .../processor/MultiReducerProcessor.java | 36 +- .../processor/PartitionPersistProcessor.java | 45 +- .../planner/processor/ProjectedProcessor.java | 33 +- .../planner/processor/StateQueryProcessor.java | 52 +- .../planner/processor/TridentContext.java | 45 +- .../storm/trident/spout/BatchSpoutExecutor.java | 85 +- .../apache/storm/trident/spout/IBatchID.java | 20 +- .../apache/storm/trident/spout/IBatchSpout.java | 29 +- .../trident/spout/ICommitterTridentSpout.java | 29 +- .../spout/IOpaquePartitionedTridentSpout.java | 95 +- .../trident/spout/IPartitionedTridentSpout.java | 75 +- .../storm/trident/spout/ISpoutPartition.java | 19 +- .../storm/trident/spout/ITridentDataSource.java | 1 + .../storm/trident/spout/ITridentSpout.java | 131 +- .../OpaquePartitionedTridentSpoutExecutor.java | 164 +- .../spout/PartitionedTridentSpoutExecutor.java | 138 +- .../trident/spout/RichSpoutBatchExecutor.java | 196 +- .../storm/trident/spout/RichSpoutBatchId.java | 29 +- .../spout/RichSpoutBatchIdSerializer.java | 21 +- .../trident/spout/RichSpoutBatchTriggerer.java | 85 +- .../trident/spout/TridentSpoutCoordinator.java | 37 +- .../trident/spout/TridentSpoutExecutor.java | 65 +- .../storm/trident/state/BaseQueryFunction.java | 21 +- .../storm/trident/state/BaseStateUpdater.java | 21 +- .../trident/state/CombinerValueUpdater.java | 28 +- .../storm/trident/state/ITupleCollection.java | 19 +- .../state/JSONNonTransactionalSerializer.java | 21 +- .../trident/state/JSONOpaqueSerializer.java | 21 +- .../state/JSONTransactionalSerializer.java | 21 +- .../apache/storm/trident/state/OpaqueValue.java | 39 +- .../storm/trident/state/QueryFunction.java | 20 +- .../storm/trident/state/ReadOnlyState.java | 21 +- .../trident/state/ReducerValueUpdater.java | 27 +- .../apache/storm/trident/state/Serializer.java | 20 +- .../org/apache/storm/trident/state/State.java | 41 +- .../storm/trident/state/StateFactory.java | 21 +- .../apache/storm/trident/state/StateSpec.java | 21 +- .../apache/storm/trident/state/StateType.java | 19 +- .../storm/trident/state/StateUpdater.java | 19 +- .../storm/trident/state/TransactionalValue.java | 27 +- .../storm/trident/state/ValueUpdater.java | 19 +- .../trident/state/map/CachedBatchReadsMap.java | 56 +- .../storm/trident/state/map/CachedMap.java | 30 +- .../storm/trident/state/map/IBackingMap.java | 24 +- .../state/map/MapCombinerAggStateUpdater.java | 42 +- .../state/map/MapReducerAggStateUpdater.java | 35 +- .../storm/trident/state/map/MapState.java | 20 +- .../state/map/MicroBatchIBackingMap.java | 51 +- .../trident/state/map/NonTransactionalMap.java | 38 +- .../storm/trident/state/map/OpaqueMap.java | 62 +- .../trident/state/map/ReadOnlyMapState.java | 19 +- .../trident/state/map/RemovableMapState.java | 19 +- .../trident/state/map/SnapshottableMap.java | 21 +- .../trident/state/map/TransactionalMap.java | 52 +- .../state/snapshot/ReadOnlySnapshottable.java | 21 +- .../trident/state/snapshot/Snapshottable.java | 20 +- .../trident/testing/CountAsAggregator.java | 31 +- .../storm/trident/testing/FeederBatchSpout.java | 181 +- .../testing/FeederCommitterBatchSpout.java | 86 +- .../storm/trident/testing/FixedBatchSpout.java | 50 +- .../apache/storm/trident/testing/IFeeder.java | 21 +- .../trident/testing/LRUMemoryMapState.java | 46 +- .../storm/trident/testing/MemoryBackingMap.java | 26 +- .../storm/trident/testing/MemoryMapState.java | 58 +- .../org/apache/storm/trident/testing/Split.java | 27 +- .../storm/trident/testing/StringLength.java | 23 +- .../storm/trident/testing/TrueFilter.java | 21 +- .../storm/trident/testing/TuplifyArgs.java | 25 +- .../storm/trident/topology/BatchInfo.java | 21 +- .../trident/topology/ITridentBatchBolt.java | 27 +- .../topology/MasterBatchCoordinator.java | 211 +- .../trident/topology/TransactionAttempt.java | 39 +- .../trident/topology/TridentBoltExecutor.java | 489 ++--- .../topology/TridentTopologyBuilder.java | 360 ++-- .../state/RotatingTransactionalState.java | 107 +- .../topology/state/TestTransactionalState.java | 31 +- .../topology/state/TransactionalState.java | 115 +- .../apache/storm/trident/tuple/ComboList.java | 85 +- .../apache/storm/trident/tuple/ConsList.java | 24 +- .../storm/trident/tuple/TridentTuple.java | 24 +- .../storm/trident/tuple/TridentTupleView.java | 359 ++- .../storm/trident/tuple/ValuePointer.java | 52 +- .../storm/trident/util/ErrorEdgeFactory.java | 21 +- .../apache/storm/trident/util/IndexedEdge.java | 23 +- .../org/apache/storm/trident/util/LRUMap.java | 21 +- .../apache/storm/trident/util/TridentUtils.java | 80 +- .../windowing/AbstractTridentWindowManager.java | 119 +- .../windowing/ITridentWindowManager.java | 33 +- .../windowing/InMemoryTridentWindowManager.java | 22 +- .../trident/windowing/InMemoryWindowsStore.java | 56 +- .../windowing/InMemoryWindowsStoreFactory.java | 34 +- .../StoreBasedTridentWindowManager.java | 59 +- .../trident/windowing/TridentBatchTuple.java | 20 +- .../trident/windowing/WindowKryoSerializer.java | 28 +- .../windowing/WindowTridentProcessor.java | 114 +- .../storm/trident/windowing/WindowsState.java | 25 +- .../trident/windowing/WindowsStateFactory.java | 24 +- .../trident/windowing/WindowsStateUpdater.java | 33 +- .../storm/trident/windowing/WindowsStore.java | 26 +- .../trident/windowing/WindowsStoreFactory.java | 30 +- .../windowing/config/BaseWindowConfig.java | 23 +- .../windowing/config/SlidingCountWindow.java | 33 +- .../windowing/config/SlidingDurationWindow.java | 33 +- .../windowing/config/TumblingCountWindow.java | 31 +- .../config/TumblingDurationWindow.java | 28 +- .../trident/windowing/config/WindowConfig.java | 25 +- .../windowing/strategy/BaseWindowStrategy.java | 20 +- .../strategy/SlidingCountWindowStrategy.java | 24 +- .../strategy/SlidingDurationWindowStrategy.java | 25 +- .../strategy/TumblingCountWindowStrategy.java | 27 +- .../TumblingDurationWindowStrategy.java | 25 +- .../windowing/strategy/WindowStrategy.java | 24 +- .../org/apache/storm/tuple/AddressedTuple.java | 33 +- .../src/jvm/org/apache/storm/tuple/Fields.java | 72 +- .../src/jvm/org/apache/storm/tuple/ITuple.java | 135 +- .../jvm/org/apache/storm/tuple/MessageId.java | 55 +- .../src/jvm/org/apache/storm/tuple/Tuple.java | 45 +- .../jvm/org/apache/storm/tuple/TupleImpl.java | 62 +- .../src/jvm/org/apache/storm/tuple/Values.java | 30 +- .../jvm/org/apache/storm/utils/BatchHelper.java | 21 +- .../storm/utils/BufferFileInputStream.java | 25 +- .../apache/storm/utils/CRC32OutputStream.java | 25 +- .../jvm/org/apache/storm/utils/ConfigUtils.java | 53 +- .../org/apache/storm/utils/CuratorUtils.java | 38 +- .../jvm/org/apache/storm/utils/DRPCClient.java | 113 +- .../storm/utils/DefaultShellLogHandler.java | 44 +- .../utils/DisallowedStrategyException.java | 6 +- .../storm/utils/ExtendedThreadPoolExecutor.java | 66 +- .../jvm/org/apache/storm/utils/IPredicate.java | 26 +- .../org/apache/storm/utils/InprocMessaging.java | 42 +- .../src/jvm/org/apache/storm/utils/JCQueue.java | 454 ++-- .../storm/utils/KeyedRoundRobinQueue.java | 29 +- .../org/apache/storm/utils/ListDelegate.java | 37 +- .../jvm/org/apache/storm/utils/LocalState.java | 66 +- .../jvm/org/apache/storm/utils/MutableInt.java | 29 +- .../jvm/org/apache/storm/utils/MutableLong.java | 29 +- .../org/apache/storm/utils/MutableObject.java | 33 +- .../org/apache/storm/utils/NimbusClient.java | 129 +- .../utils/NimbusLeaderNotFoundException.java | 8 +- .../org/apache/storm/utils/ObjectReader.java | 10 +- .../org/apache/storm/utils/ReflectionUtils.java | 17 +- .../storm/utils/RegisteredGlobalState.java | 50 +- .../jvm/org/apache/storm/utils/RotatingMap.java | 75 +- .../org/apache/storm/utils/ServiceRegistry.java | 37 +- .../storm/utils/ShellBoltMessageQueue.java | 42 +- .../apache/storm/utils/ShellCommandRunner.java | 39 +- .../storm/utils/ShellCommandRunnerImpl.java | 2 +- .../org/apache/storm/utils/ShellLogHandler.java | 40 +- .../org/apache/storm/utils/ShellProcess.java | 59 +- .../jvm/org/apache/storm/utils/ShellUtils.java | 365 ++-- .../org/apache/storm/utils/SimpleVersion.java | 44 +- .../StormBoundedExponentialBackoffRetry.java | 48 +- .../apache/storm/utils/SupervisorClient.java | 68 +- .../apache/storm/utils/ThriftTopologyUtils.java | 23 +- .../src/jvm/org/apache/storm/utils/Time.java | 161 +- .../org/apache/storm/utils/TimeCacheMap.java | 62 +- .../org/apache/storm/utils/TransferDrainer.java | 19 +- .../jvm/org/apache/storm/utils/TupleUtils.java | 60 +- .../src/jvm/org/apache/storm/utils/Utils.java | 566 ++--- .../jvm/org/apache/storm/utils/VersionInfo.java | 205 +- .../org/apache/storm/utils/VersionedStore.java | 83 +- .../storm/utils/WindowedTimeThrottler.java | 31 +- .../org/apache/storm/utils/WritableUtils.java | 662 +++--- .../apache/storm/utils/ZookeeperAuthInfo.java | 29 +- .../storm/utils/ZookeeperServerCnxnFactory.java | 123 +- .../storm/validation/ConfigValidation.java | 610 +++--- .../validation/ConfigValidationAnnotations.java | 82 +- .../storm/validation/ConfigValidationUtils.java | 120 +- .../org/apache/storm/validation/NotConf.java | 21 +- .../org/apache/storm/validation/Validated.java | 19 +- .../storm/windowing/CountEvictionPolicy.java | 36 +- .../storm/windowing/CountTriggerPolicy.java | 30 +- .../storm/windowing/DefaultEvictionContext.java | 21 +- .../jvm/org/apache/storm/windowing/Event.java | 27 +- .../org/apache/storm/windowing/EventImpl.java | 25 +- .../apache/storm/windowing/EvictionContext.java | 27 +- .../apache/storm/windowing/EvictionPolicy.java | 90 +- .../storm/windowing/StatefulWindowManager.java | 67 +- .../storm/windowing/TimeEvictionPolicy.java | 46 +- .../storm/windowing/TimeTriggerPolicy.java | 49 +- .../storm/windowing/TimestampExtractor.java | 22 +- .../apache/storm/windowing/TriggerHandler.java | 22 +- .../apache/storm/windowing/TriggerPolicy.java | 25 +- .../org/apache/storm/windowing/TupleWindow.java | 19 +- .../apache/storm/windowing/TupleWindowImpl.java | 46 +- .../storm/windowing/TupleWindowIterImpl.java | 18 +- .../apache/storm/windowing/WaterMarkEvent.java | 22 +- .../windowing/WaterMarkEventGenerator.java | 47 +- .../windowing/WatermarkCountEvictionPolicy.java | 31 +- .../windowing/WatermarkCountTriggerPolicy.java | 33 +- .../windowing/WatermarkTimeEvictionPolicy.java | 44 +- .../windowing/WatermarkTimeTriggerPolicy.java | 47 +- .../jvm/org/apache/storm/windowing/Window.java | 45 +- .../windowing/WindowLifecycleListener.java | 39 +- .../apache/storm/windowing/WindowManager.java | 108 +- .../persistence/SimpleWindowPartitionCache.java | 50 +- .../persistence/WindowPartitionCache.java | 21 +- .../windowing/persistence/WindowState.java | 39 +- .../apache/storm/zookeeper/ClientZookeeper.java | 48 +- .../apache/storm/zookeeper/ZkEventTypes.java | 22 +- .../apache/storm/zookeeper/ZkKeeperStates.java | 22 +- .../storm/PaceMakerStateStorageFactoryTest.java | 92 +- .../org/apache/storm/TestConfigValidate.java | 225 +- .../LocalAssignmentsBackendTest.java | 17 +- .../storm/blobstore/ClientBlobStoreTest.java | 290 ++- .../jvm/org/apache/storm/bolt/TestJoinBolt.java | 299 ++- .../apache/storm/cluster/DaemonTypeTest.java | 21 +- .../cluster/StormClusterStateImplTest.java | 36 +- .../daemon/worker/LogConfigManagerTest.java | 112 +- .../apache/storm/daemon/worker/WorkerTest.java | 22 +- .../DependencyPropertiesParserTest.java | 26 +- .../dependency/DependencyUploaderTest.java | 29 +- .../storm/executor/error/ReportErrorTest.java | 38 +- .../grouping/LoadAwareShuffleGroupingTest.java | 87 +- .../storm/grouping/ShuffleGroupingTest.java | 32 +- .../BalancedTargetSelectorTest.java | 32 +- .../PartialKeyGroupingTest.java | 22 +- .../RandomTwoTaskAssignmentCreatorTest.java | 19 +- .../DeserializingConnectionCallbackTest.java | 33 +- .../metric/filter/FilterByMetricNameTest.java | 29 +- .../metric/internal/CountStatAndMetricTest.java | 47 +- .../internal/LatencyStatAndMetricTest.java | 39 +- .../storm/metric/internal/RateTrackerTest.java | 30 +- .../metric/util/DataPointExpanderTest.java | 172 +- .../storm/security/auth/AuthUtilsTest.java | 93 +- .../storm/security/auth/AuthUtilsTestMock.java | 36 +- .../apache/storm/security/auth/AutoSSLTest.java | 81 +- .../auth/DefaultHttpCredentialsPluginTest.java | 29 +- .../storm/security/auth/ReqContextTest.java | 28 +- .../security/auth/SaslTransportPluginTest.java | 19 +- .../auth/ShellBasedGroupsMappingTest.java | 40 +- .../storm/security/auth/ThriftClientTest.java | 29 +- .../authorizer/DRPCSimpleACLAuthorizerTest.java | 132 +- .../authorizer/SimpleACLAuthorizerTest.java | 505 +++-- .../BlowfishTupleSerializerTest.java | 51 +- .../GzipBridgeSerializationDelegateTest.java | 31 +- ...ipBridgeThriftSerializationDelegateTest.java | 28 +- .../serialization/SerializationFactoryTest.java | 23 +- .../ThriftBridgeSerializationDelegateTest.java | 22 +- .../apache/storm/spout/CheckpointSpoutTest.java | 38 +- .../state/BaseBinaryStateIteratorTest.java | 255 ++- .../storm/state/DefaultStateSerializerTest.java | 8 +- .../storm/state/InMemoryKeyValueStateTest.java | 50 +- .../apache/storm/streams/ProcessorBoltTest.java | 44 +- .../streams/StatefulProcessorBoltTest.java | 30 +- .../apache/storm/streams/StreamBuilderTest.java | 133 +- .../streams/WindowedProcessorBoltTest.java | 26 +- .../processors/CoGroupByKeyProcessorTest.java | 49 +- .../streams/processors/JoinProcessorTest.java | 51 +- .../PersistentWindowedBoltExecutorTest.java | 68 +- .../SimpleWindowPartitionCacheTest.java | 31 +- .../topology/StatefulBoltExecutorTest.java | 36 +- .../StatefulWindowedBoltExecutorTest.java | 30 +- .../storm/topology/TopologyBuilderTest.java | 41 +- .../topology/WindowedBoltExecutorTest.java | 84 +- .../storm/trident/TestTridentTopology.java | 39 +- .../storm/trident/TridentWindowingTest.java | 65 +- .../jvm/org/apache/storm/tuple/FieldsTest.java | 35 +- .../org/apache/storm/utils/ConfigUtilsTest.java | 24 +- .../apache/storm/utils/CuratorUtilsTest.java | 15 +- .../storm/utils/DefaultShellLogHandlerTest.java | 27 +- .../storm/utils/JCQueueBackpressureTest.java | 69 +- .../jvm/org/apache/storm/utils/JCQueueTest.java | 74 +- .../apache/storm/utils/MockTupleHelpers.java | 42 +- .../storm/utils/ShellBoltMessageQueueTest.java | 26 +- .../org/apache/storm/utils/ShellUtilsTest.java | 50 +- ...StormBoundedExponentialBackoffRetryTest.java | 43 +- .../storm/utils/ThriftTopologyUtilsTest.java | 46 +- .../utils/ThrowableNestedCauseMatcher.java | 9 +- .../jvm/org/apache/storm/utils/TimeTest.java | 36 +- .../jvm/org/apache/storm/utils/UtilsTest.java | 90 +- .../utils/ZookeeperServerCnxnFactoryTest.java | 19 +- .../windowing/WaterMarkEventGeneratorTest.java | 33 +- .../storm/windowing/WindowManagerTest.java | 154 +- .../windowing/persistence/WindowStateTest.java | 47 +- storm-core/pom.xml | 2 +- .../jvm/org/apache/storm/command/Activate.java | 32 +- .../org/apache/storm/command/AdminCommands.java | 39 +- .../apache/storm/command/BasicDrpcClient.java | 30 +- .../jvm/org/apache/storm/command/Blobstore.java | 85 +- .../src/jvm/org/apache/storm/command/CLI.java | 303 ++- .../org/apache/storm/command/ConfigValue.java | 26 +- .../org/apache/storm/command/Deactivate.java | 32 +- .../org/apache/storm/command/DevZookeeper.java | 20 +- .../jvm/org/apache/storm/command/GetErrors.java | 28 +- .../org/apache/storm/command/HealthCheck.java | 20 +- .../org/apache/storm/command/Heartbeats.java | 23 +- .../org/apache/storm/command/KillTopology.java | 39 +- .../org/apache/storm/command/KillWorkers.java | 24 +- .../apache/storm/command/ListTopologies.java | 55 +- .../jvm/org/apache/storm/command/Monitor.java | 31 +- .../jvm/org/apache/storm/command/Rebalance.java | 39 +- .../org/apache/storm/command/SetLogLevel.java | 32 +- .../apache/storm/command/UploadCredentials.java | 40 +- .../org/apache/storm/planner/CompoundSpout.java | 21 +- .../org/apache/storm/planner/CompoundTask.java | 21 +- .../org/apache/storm/planner/TaskBundle.java | 25 +- .../apache/storm/testing/MockLeaderElector.java | 23 +- .../staticmocking/MockedClientZookeeper.java | 1 + .../testing/staticmocking/MockedCluster.java | 20 +- .../staticmocking/MockedSupervisorUtils.java | 18 +- .../testing/staticmocking/MockedZookeeper.java | 18 +- .../apache/storm/ui/FilterConfiguration.java | 19 +- .../jvm/org/apache/storm/ui/IConfigurator.java | 19 +- .../storm/ui/InvalidRequestException.java | 1 + .../src/jvm/org/apache/storm/ui/UIHelpers.java | 70 +- .../apache/storm/utils/ClojureTimerTask.java | 25 +- .../src/jvm/org/apache/storm/utils/Monitor.java | 185 +- .../apache/storm/utils/TopologySpoutLag.java | 75 +- .../test/jvm/org/apache/storm/MockAutoCred.java | 25 +- .../org/apache/storm/command/RebalanceTest.java | 21 +- .../apache/storm/command/SetLogLevelTest.java | 21 +- .../jvm/org/apache/storm/command/TestCLI.java | 48 +- .../apache/storm/metric/FakeMetricConsumer.java | 41 +- .../nimbus/InMemoryTopologyActionNotifier.java | 27 +- .../storm/serialization/SerializationTest.java | 10 +- .../org/apache/storm/stats/TestStatsUtil.java | 64 +- .../staticmocking/ConfigUtilsInstaller.java | 3 +- .../staticmocking/ReflectionUtilsInstaller.java | 3 +- .../ServerConfigUtilsInstaller.java | 3 +- .../utils/staticmocking/UtilsInstaller.java | 3 +- .../storm/utils/staticmocking/package-info.java | 66 +- storm-server/pom.xml | 2 +- .../java/org/apache/storm/DaemonConfig.java | 454 ++-- .../ILocalClusterTrackedTopologyAware.java | 25 +- .../java/org/apache/storm/LocalCluster.java | 809 ++++--- .../main/java/org/apache/storm/LocalDRPC.java | 12 +- .../java/org/apache/storm/ProcessSimulator.java | 34 +- .../src/main/java/org/apache/storm/Testing.java | 330 ++- .../storm/blobstore/BlobKeySequenceInfo.java | 35 +- .../apache/storm/blobstore/BlobStoreUtils.java | 35 +- .../storm/blobstore/BlobSynchronizer.java | 49 +- .../storm/blobstore/FileBlobStoreImpl.java | 154 +- .../storm/blobstore/KeySequenceNumber.java | 38 +- .../storm/blobstore/LocalFsBlobStore.java | 84 +- .../storm/blobstore/LocalFsBlobStoreFile.java | 36 +- .../container/ResourceIsolationInterface.java | 18 +- .../storm/container/cgroup/CgroupManager.java | 85 +- .../daemon/drpc/BlockingOutstandingRequest.java | 6 +- .../java/org/apache/storm/daemon/drpc/DRPC.java | 87 +- .../apache/storm/daemon/drpc/DRPCThrift.java | 3 +- .../storm/daemon/drpc/OutstandingRequest.java | 4 +- .../storm/daemon/drpc/RequestFactory.java | 3 +- .../storm/daemon/metrics/MetricsUtils.java | 1 - .../reporters/ConsolePreparableReporter.java | 18 +- .../reporters/CsvPreparableReporter.java | 18 +- .../reporters/JmxPreparableReporter.java | 18 +- .../metrics/reporters/PreparableReporter.java | 28 +- .../org/apache/storm/daemon/nimbus/Nimbus.java | 2040 +++++++++--------- .../apache/storm/daemon/nimbus/TopoCache.java | 46 +- .../storm/daemon/nimbus/TopologyActions.java | 23 +- .../storm/daemon/nimbus/TopologyResources.java | 107 +- .../daemon/nimbus/TopologyStateTransition.java | 23 +- .../storm/daemon/supervisor/BasicContainer.java | 675 +++--- .../supervisor/BasicContainerLauncher.java | 32 +- .../storm/daemon/supervisor/Container.java | 305 +-- .../daemon/supervisor/ContainerLauncher.java | 48 +- .../supervisor/ContainerRecoveryException.java | 19 +- .../DefaultUncaughtExceptionHandler.java | 20 +- .../supervisor/EventManagerPushCallback.java | 19 +- .../storm/daemon/supervisor/Killable.java | 27 +- .../storm/daemon/supervisor/LocalContainer.java | 26 +- .../supervisor/LocalContainerLauncher.java | 22 +- .../daemon/supervisor/OnlyLatestExecutor.java | 9 +- .../daemon/supervisor/ReadClusterState.java | 109 +- .../daemon/supervisor/RunAsUserContainer.java | 25 +- .../supervisor/RunAsUserContainerLauncher.java | 34 +- .../apache/storm/daemon/supervisor/Slot.java | 863 ++++---- .../daemon/supervisor/StandaloneSupervisor.java | 30 +- .../storm/daemon/supervisor/Supervisor.java | 184 +- .../daemon/supervisor/SupervisorUtils.java | 59 +- .../apache/storm/daemon/supervisor/UniFunc.java | 19 +- .../timer/ReportWorkerHeartbeats.java | 19 +- .../supervisor/timer/SupervisorHealthCheck.java | 1 - .../supervisor/timer/SupervisorHeartbeat.java | 24 +- .../timer/SynchronizeAssignments.java | 43 +- .../org/apache/storm/event/EventManager.java | 19 +- .../org/apache/storm/event/EventManagerImp.java | 30 +- .../apache/storm/healthcheck/HealthChecker.java | 19 +- .../apache/storm/localizer/AsyncLocalizer.java | 278 +-- .../storm/localizer/BlobChangingCallback.java | 14 +- .../org/apache/storm/localizer/GoodToGo.java | 46 +- .../apache/storm/localizer/LocalResource.java | 18 +- .../storm/localizer/LocalizedResource.java | 93 +- .../LocalizedResourceRetentionSet.java | 28 +- .../storm/localizer/LocallyCachedBlob.java | 115 +- .../localizer/LocallyCachedTopologyBlob.java | 164 +- .../storm/localizer/PortAndAssignment.java | 18 +- .../storm/logging/ThriftAccessLogger.java | 20 +- .../logging/filters/AccessLoggingFilter.java | 21 +- .../metric/ClusterMetricsConsumerExecutor.java | 32 +- .../metric/LoggingClusterMetricsConsumer.java | 38 +- .../storm/metric/StormMetricsRegistry.java | 29 +- .../org/apache/storm/metric/api/DataPoint.java | 19 +- .../metric/api/IClusterMetricsConsumer.java | 32 +- .../org/apache/storm/metricstore/AggLevel.java | 21 +- .../apache/storm/metricstore/FilterOptions.java | 79 +- .../org/apache/storm/metricstore/Metric.java | 82 +- .../storm/metricstore/MetricException.java | 19 +- .../apache/storm/metricstore/MetricStore.java | 21 +- .../storm/metricstore/MetricStoreConfig.java | 23 +- .../metricstore/NimbusMetricProcessor.java | 21 +- .../metricstore/WorkerMetricsProcessor.java | 19 +- .../storm/metricstore/rocksdb/KeyType.java | 32 +- .../metricstore/rocksdb/MetricsCleaner.java | 19 +- .../rocksdb/ReadOnlyStringMetadataCache.java | 25 +- .../storm/metricstore/rocksdb/RocksDbKey.java | 114 +- .../rocksdb/RocksDbMetricsWriter.java | 35 +- .../storm/metricstore/rocksdb/RocksDbStore.java | 50 +- .../storm/metricstore/rocksdb/RocksDbValue.java | 25 +- .../metricstore/rocksdb/StringMetadata.java | 19 +- .../rocksdb/StringMetadataCache.java | 57 +- .../rocksdb/WritableStringMetadataCache.java | 22 +- .../nimbus/AssignmentDistributionService.java | 130 +- .../storm/nimbus/DefaultTopologyValidator.java | 22 +- .../org/apache/storm/nimbus/ILeaderElector.java | 21 +- .../nimbus/ITopologyActionNotifierPlugin.java | 19 +- .../apache/storm/nimbus/ITopologyValidator.java | 23 +- .../IWorkerHeartbeatsRecoveryStrategy.java | 18 +- .../storm/nimbus/LeaderListenerCallback.java | 58 +- .../nimbus/NimbusHeartbeatsPressureTest.java | 124 +- .../storm/nimbus/StrictTopologyValidator.java | 22 +- ...TimeOutWorkerHeartbeatsRecoveryStrategy.java | 20 +- ...WorkerHeartbeatsRecoveryStrategyFactory.java | 24 +- .../storm/pacemaker/IServerMessageHandler.java | 19 +- .../org/apache/storm/pacemaker/Pacemaker.java | 123 +- .../apache/storm/pacemaker/PacemakerServer.java | 109 +- .../pacemaker/codec/ThriftNettyServerCodec.java | 67 +- .../org/apache/storm/scheduler/Cluster.java | 219 +- .../org/apache/storm/scheduler/Component.java | 22 +- .../storm/scheduler/DefaultScheduler.java | 9 +- .../apache/storm/scheduler/EvenScheduler.java | 4 +- .../apache/storm/scheduler/ExecutorDetails.java | 6 +- .../org/apache/storm/scheduler/INimbus.java | 22 +- .../org/apache/storm/scheduler/IScheduler.java | 22 +- .../storm/scheduler/ISchedulingState.java | 118 +- .../org/apache/storm/scheduler/ISupervisor.java | 21 +- .../storm/scheduler/IsolationScheduler.java | 51 +- .../storm/scheduler/SchedulerAssignment.java | 20 +- .../scheduler/SchedulerAssignmentImpl.java | 35 +- .../storm/scheduler/SingleTopologyCluster.java | 2 +- .../storm/scheduler/SupervisorDetails.java | 51 +- .../storm/scheduler/SupervisorResources.java | 4 +- .../org/apache/storm/scheduler/Topologies.java | 30 +- .../apache/storm/scheduler/TopologyDetails.java | 94 +- .../scheduler/blacklist/BlacklistScheduler.java | 44 +- .../blacklist/reporters/IReporter.java | 18 +- .../blacklist/reporters/LogReporter.java | 21 +- .../strategies/DefaultBlacklistStrategy.java | 29 +- .../strategies/IBlacklistStrategy.java | 19 +- .../scheduler/multitenant/DefaultPool.java | 363 ++-- .../storm/scheduler/multitenant/FreePool.java | 182 +- .../scheduler/multitenant/IsolatedPool.java | 617 +++--- .../multitenant/MultitenantScheduler.java | 186 +- .../storm/scheduler/multitenant/Node.java | 561 +++-- .../storm/scheduler/multitenant/NodePool.java | 494 +++-- .../storm/scheduler/resource/RAS_Node.java | 101 +- .../storm/scheduler/resource/RAS_Nodes.java | 8 +- .../resource/ResourceAwareScheduler.java | 90 +- .../storm/scheduler/resource/ResourceUtils.java | 34 +- .../scheduler/resource/SchedulingResult.java | 20 +- .../scheduler/resource/SchedulingStatus.java | 20 +- .../apache/storm/scheduler/resource/User.java | 10 +- .../normalization/NormalizedResourceOffer.java | 9 +- .../NormalizedResourceRequest.java | 54 +- .../normalization/NormalizedResources.java | 66 +- .../normalization/ResourceNameNormalizer.java | 10 +- .../DefaultSchedulingPriorityStrategy.java | 90 +- .../FIFOSchedulingPriorityStrategy.java | 28 +- .../priority/ISchedulingPriorityStrategy.java | 19 +- .../scheduling/BaseResourceAwareStrategy.java | 231 +- .../scheduling/ConstraintSolverStrategy.java | 709 +++--- .../DefaultResourceAwareStrategy.java | 93 +- .../GenericResourceAwareStrategy.java | 129 +- .../strategies/scheduling/IStrategy.java | 23 +- .../utils/ArtifactoryConfigLoader.java | 115 +- .../utils/ArtifactoryConfigLoaderFactory.java | 18 +- .../utils/ConfigLoaderFactoryService.java | 18 +- .../storm/scheduler/utils/FileConfigLoader.java | 19 +- .../utils/FileConfigLoaderFactory.java | 18 +- .../storm/scheduler/utils/IConfigLoader.java | 20 +- .../scheduler/utils/IConfigLoaderFactory.java | 18 +- .../auth/workertoken/WorkerTokenManager.java | 64 +- .../storm/testing/CompleteTopologyParam.java | 146 +- .../storm/testing/InProcessZookeeper.java | 27 +- .../java/org/apache/storm/testing/TestJob.java | 31 +- .../apache/storm/testing/TrackedTopology.java | 164 +- .../apache/storm/utils/BufferInputStream.java | 18 +- .../java/org/apache/storm/utils/LruMap.java | 20 +- .../apache/storm/utils/ServerConfigUtils.java | 16 +- .../org/apache/storm/utils/ServerUtils.java | 201 +- .../storm/utils/StormCommonInstaller.java | 20 +- .../apache/storm/zookeeper/AclEnforcement.java | 42 +- .../storm/zookeeper/LeaderElectorImp.java | 30 +- .../org/apache/storm/zookeeper/Zookeeper.java | 54 +- .../java/org/apache/storm/DaemonConfigTest.java | 42 +- .../java/org/apache/storm/LocalStateTest.java | 38 +- .../java/org/apache/storm/MessagingTest.java | 38 +- .../java/org/apache/storm/PacemakerTest.java | 25 +- .../test/java/org/apache/storm/TestCgroups.java | 51 +- .../apache/storm/TestDaemonConfigValidate.java | 24 +- .../java/org/apache/storm/TestRebalance.java | 47 +- .../test/java/org/apache/storm/TestingTest.java | 50 +- .../java/org/apache/storm/TickTupleTest.java | 41 +- .../apache/storm/blobstore/BlobStoreTest.java | 798 ++++--- .../storm/blobstore/BlobStoreUtilsTest.java | 34 +- .../storm/blobstore/BlobSynchronizerTest.java | 201 +- .../blobstore/MockZookeeperClientBuilder.java | 30 +- .../org/apache/storm/daemon/drpc/DRPCTest.java | 60 +- .../apache/storm/daemon/nimbus/NimbusTest.java | 3 +- .../daemon/supervisor/BasicContainerTest.java | 776 +++---- .../storm/daemon/supervisor/ContainerTest.java | 231 +- .../storm/daemon/supervisor/SlotTest.java | 259 +-- .../storm/localizer/AsyncLocalizerTest.java | 342 ++- .../LocalizedResourceRetentionSetTest.java | 31 +- .../ClusterMetricsConsumerExecutorTest.java | 73 +- .../apache/storm/nimbus/LocalNimbusTest.java | 36 +- .../org/apache/storm/scheduler/ClusterTest.java | 24 +- .../resource/TestResourceAwareScheduler.java | 99 +- .../storm/scheduler/resource/TestUser.java | 40 +- .../TestUtilsForResourceAwareScheduler.java | 88 +- .../utils/ArtifactoryConfigLoaderTest.java | 114 +- .../scheduler/utils/FileConfigLoaderTest.java | 29 +- .../apache/storm/security/auth/AuthTest.java | 356 +-- 1790 files changed, 50515 insertions(+), 58810 deletions(-) ----------------------------------------------------------------------
