925422a5b5ad1c3329a2c2b44db460ae94f70806 - storm

commit	925422a5b5ad1c3329a2c2b44db460ae94f70806	[log] [tgz]
author	Karl-Philipp Richter <krichter@posteo.de>	Sun Jul 07 18:51:36 2019 +0200
committer	Stig Døssing <srdo@apache.org>	Sun Jul 07 18:51:36 2019 +0200
tree	367e00cf1bbf2fc1d6f7c1a8770690d9c2fd569c
parent	98ac65fec88c15639f9f9a0fefba0f92d9a783cd [diff]

STORM-3440: client: fix all checkstyle warnings (#3055)

* STORM-3440: client: fix all checkstyle warnings

examples/storm-starter/src/jvm/org/apache/storm/starter/streams/AggregateExample.java[diff]
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/TypedTupleExample.java[diff]
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/Configs.java[diff]
storm-client/pom.xml[diff]
storm-client/src/jvm/org/apache/storm/Config.java[diff]
storm-client/src/jvm/org/apache/storm/ILocalCluster.java[diff]
storm-client/src/jvm/org/apache/storm/ILocalDRPC.java[diff]
storm-client/src/jvm/org/apache/storm/StormSubmitter.java[diff]
storm-client/src/jvm/org/apache/storm/StormTimer.java[diff]
storm-client/src/jvm/org/apache/storm/Thrift.java[diff]
storm-client/src/jvm/org/apache/storm/annotation/InterfaceStability.java[diff]
storm-client/src/jvm/org/apache/storm/assignments/InMemoryAssignmentBackend.java[diff]
storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java[diff]
storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreAclHandler.java[diff]
storm-client/src/jvm/org/apache/storm/blobstore/ClientBlobStore.java[diff]
storm-client/src/jvm/org/apache/storm/blobstore/NimbusBlobStore.java[diff]
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java[diff]
storm-client/src/jvm/org/apache/storm/callback/ZKStateChangedCallback.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/ClusterUtils.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/IStateStorage.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/PaceMakerStateStorage.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/PaceMakerStateStorageFactory.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/StateStorageFactory.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/ZKStateStorage.java[diff]
storm-client/src/jvm/org/apache/storm/cluster/ZKStateStorageFactory.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCenter.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommon.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommonOperation.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupOperation.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupUtils.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/Device.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/Hierarchy.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/SubSystem.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/SubSystemType.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/SystemOperation.java[diff]
storm-client/src/jvm/org/apache/storm/container/cgroup/core/BlkioCore.java[diff]
storm-client/src/jvm/org/apache/storm/coordination/BatchBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollector.java[diff]
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollectorImpl.java[diff]
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/supervisor/ClientSupervisorUtils.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/supervisor/ExitCodeCallback.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/supervisor/IAdvancedFSOps.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/worker/BackPressureTracker.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java[diff]
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java[diff]
storm-client/src/jvm/org/apache/storm/dependency/DependencyBlobStoreUtils.java[diff]
storm-client/src/jvm/org/apache/storm/dependency/DependencyUploader.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/DRPCInvocationsClient.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/JoinResult.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/KeyedFairBolt.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCInputDeclarer.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCTopologyBuilder.java[diff]
storm-client/src/jvm/org/apache/storm/drpc/ReturnResults.java[diff]
storm-client/src/jvm/org/apache/storm/executor/Executor.java[diff]
storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java[diff]
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltOutputCollectorImpl.java[diff]
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java[diff]
storm-client/src/jvm/org/apache/storm/grouping/CustomStreamGrouping.java[diff]
storm-client/src/jvm/org/apache/storm/grouping/Load.java[diff]
storm-client/src/jvm/org/apache/storm/grouping/LoadMapping.java[diff]
storm-client/src/jvm/org/apache/storm/grouping/PartialKeyGrouping.java[diff]
storm-client/src/jvm/org/apache/storm/hooks/BaseWorkerHook.java[diff]
storm-client/src/jvm/org/apache/storm/hooks/IWorkerHook.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/ConnectionWithStatus.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/DeserializingConnectionCallback.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/IConnection.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/IConnectionCallback.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/IContext.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/TaskMessage.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/TransportFactory.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/local/Context.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/ControlMessage.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslNettyClient.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslNettyClientState.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslNettyServer.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslNettyServerState.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslServerHandler.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/Login.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageBatch.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageDecoder.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslMessageToken.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyClient.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java[diff]
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerHandler.java[diff]
storm-client/src/jvm/org/apache/storm/metric/EventLoggerBolt.java[diff]
storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java[diff]
storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java[diff]
storm-client/src/jvm/org/apache/storm/metric/MetricsConsumerBolt.java[diff]
storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/AssignableMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/CombinedMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/CountMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/IMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/IMetricsConsumer.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/MeanReducer.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/MeanReducerState.java[Added - diff]
storm-client/src/jvm/org/apache/storm/metric/api/MultiCountMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/MultiReducedMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/ReducedMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/StateMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/rpc/CountShellMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/api/rpc/IShellMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/cgroup/CGroupCpu.java[diff]
storm-client/src/jvm/org/apache/storm/metric/cgroup/CGroupMemoryLimit.java[diff]
storm-client/src/jvm/org/apache/storm/metric/cgroup/CGroupMemoryUsage.java[diff]
storm-client/src/jvm/org/apache/storm/metric/internal/CountStatAndMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/internal/LatencyStatAndMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/internal/MetricStatTimer.java[diff]
storm-client/src/jvm/org/apache/storm/metric/internal/MultiCountStatAndMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/internal/MultiLatencyStatAndMetric.java[diff]
storm-client/src/jvm/org/apache/storm/metric/internal/RateTracker.java[diff]
storm-client/src/jvm/org/apache/storm/multilang/BoltMsg.java[diff]
storm-client/src/jvm/org/apache/storm/multilang/ISerializer.java[diff]
storm-client/src/jvm/org/apache/storm/multilang/JsonSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/multilang/ShellMsg.java[diff]
storm-client/src/jvm/org/apache/storm/multilang/SpoutMsg.java[diff]
storm-client/src/jvm/org/apache/storm/networktopography/AbstractDNSToSwitchMapping.java[diff]
storm-client/src/jvm/org/apache/storm/networktopography/DNSToSwitchMapping.java[diff]
storm-client/src/jvm/org/apache/storm/networktopography/DefaultRackDNSToSwitchMapping.java[diff]
storm-client/src/jvm/org/apache/storm/nimbus/NimbusInfo.java[diff]
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClient.java[diff]
storm-client/src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java[diff]
storm-client/src/jvm/org/apache/storm/pacemaker/codec/ThriftEncoder.java[diff]
storm-client/src/jvm/org/apache/storm/pacemaker/codec/ThriftNettyClientCodec.java[diff]
storm-client/src/jvm/org/apache/storm/policy/IWaitStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/policy/WaitStrategyPark.java[diff]
storm-client/src/jvm/org/apache/storm/policy/WaitStrategyProgressive.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/AutoSSL.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ClientAuthUtils.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/DefaultPrincipalToLocal.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/FixedGroupsMapping.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/IAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/IGroupMappingServiceProvider.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/IPrincipalToLocal.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ITransportPlugin.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/KerberosPrincipalToLocal.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ReqContext.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ShellBasedGroupsMapping.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/SingleUserPrincipal.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/TBackoffConnect.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ThriftClient.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/ThriftServer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/DRPCAuthorizerBase.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/DRPCSimpleACLAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/DenyAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/ImpersonationAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/NoopAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/SimpleWhitelistAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/SupervisorSimpleACLAuthorizer.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGTKrb5LoginModule.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGTKrb5LoginModuleTest.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/ClientCallbackHandler.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/KerberosSaslTransportPlugin.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/ServerCallbackHandler.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/plain/PlainSaslTransportPlugin.java[diff]
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java[diff]
storm-client/src/jvm/org/apache/storm/security/serialization/BlowfishTupleSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/DefaultKryoFactory.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/GzipBridgeThriftSerializationDelegate.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/IKryoFactory.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/KryoTupleDeserializer.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/KryoTupleSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/KryoValuesDeserializer.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/KryoValuesSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java[diff]
storm-client/src/jvm/org/apache/storm/serialization/SerializationRegister.java[diff]
storm-client/src/jvm/org/apache/storm/spout/CheckPointState.java[diff]
storm-client/src/jvm/org/apache/storm/spout/CheckpointSpout.java[diff]
storm-client/src/jvm/org/apache/storm/spout/ISpout.java[diff]
storm-client/src/jvm/org/apache/storm/spout/RawMultiScheme.java[diff]
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java[diff]
storm-client/src/jvm/org/apache/storm/spout/SpoutOutputCollector.java[diff]
storm-client/src/jvm/org/apache/storm/state/BaseStateIterator.java[diff]
storm-client/src/jvm/org/apache/storm/state/DefaultStateEncoder.java[diff]
storm-client/src/jvm/org/apache/storm/state/InMemoryKeyValueState.java[diff]
storm-client/src/jvm/org/apache/storm/state/InMemoryKeyValueStateProvider.java[diff]
storm-client/src/jvm/org/apache/storm/state/KeyValueState.java[diff]
storm-client/src/jvm/org/apache/storm/state/StateEncoder.java[diff]
storm-client/src/jvm/org/apache/storm/state/StateFactory.java[diff]
storm-client/src/jvm/org/apache/storm/stats/ClientStatsUtil.java[diff]
storm-client/src/jvm/org/apache/storm/streams/Edge.java[diff]
storm-client/src/jvm/org/apache/storm/streams/GroupingInfo.java[diff]
storm-client/src/jvm/org/apache/storm/streams/Node.java[diff]
storm-client/src/jvm/org/apache/storm/streams/Pair.java[diff]
storm-client/src/jvm/org/apache/storm/streams/PairStream.java[diff]
storm-client/src/jvm/org/apache/storm/streams/ProcessorBolt.java[diff]
storm-client/src/jvm/org/apache/storm/streams/ProcessorBoltDelegate.java[diff]
storm-client/src/jvm/org/apache/storm/streams/ProcessorNode.java[diff]
storm-client/src/jvm/org/apache/storm/streams/RefCountedTuple.java[diff]
storm-client/src/jvm/org/apache/storm/streams/SpoutNode.java[diff]
storm-client/src/jvm/org/apache/storm/streams/StatefulProcessorBolt.java[diff]
storm-client/src/jvm/org/apache/storm/streams/Stream.java[diff]
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java[diff]
storm-client/src/jvm/org/apache/storm/streams/StreamState.java[diff]
storm-client/src/jvm/org/apache/storm/streams/StreamUtil.java[diff]
storm-client/src/jvm/org/apache/storm/streams/WindowedProcessorBolt.java[diff]
storm-client/src/jvm/org/apache/storm/streams/operations/aggregators/LongSum.java[diff]
storm-client/src/jvm/org/apache/storm/streams/operations/mappers/TupleValueMappers.java[diff]
storm-client/src/jvm/org/apache/storm/streams/operations/mappers/ValuesMapper.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/AggregateByKeyProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/AggregateProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/BaseProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/ChainedProcessorContext.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/CoGroupByKeyProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/EmittingProcessorContext.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/ForwardingProcessorContext.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/JoinProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/streams/processors/StatefulProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple10.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple3.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple4.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple5.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple6.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple7.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple8.java[diff]
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple9.java[diff]
storm-client/src/jvm/org/apache/storm/streams/windowing/TumblingWindows.java[diff]
storm-client/src/jvm/org/apache/storm/streams/windowing/Window.java[diff]
storm-client/src/jvm/org/apache/storm/task/GeneralTopologyContext.java[diff]
storm-client/src/jvm/org/apache/storm/task/IBolt.java[diff]
storm-client/src/jvm/org/apache/storm/task/IMetricsContext.java[diff]
storm-client/src/jvm/org/apache/storm/task/OutputCollector.java[diff]
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java[diff]
storm-client/src/jvm/org/apache/storm/task/TopologyContext.java[diff]
storm-client/src/jvm/org/apache/storm/task/WorkerTopologyContext.java[diff]
storm-client/src/jvm/org/apache/storm/testing/AckFailMapTracker.java[diff]
storm-client/src/jvm/org/apache/storm/testing/AckTracker.java[diff]
storm-client/src/jvm/org/apache/storm/testing/AlternateRackDNSToSwitchMapping.java[diff]
storm-client/src/jvm/org/apache/storm/testing/BoltTracker.java[diff]
storm-client/src/jvm/org/apache/storm/testing/CompletableSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/FeederSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/ForwardingMetricsConsumer.java[diff]
storm-client/src/jvm/org/apache/storm/testing/IdentityBolt.java[diff]
storm-client/src/jvm/org/apache/storm/testing/MkClusterParam.java[diff]
storm-client/src/jvm/org/apache/storm/testing/NGrouping.java[diff]
storm-client/src/jvm/org/apache/storm/testing/NonRichBoltTracker.java[diff]
storm-client/src/jvm/org/apache/storm/testing/PrepareBatchBolt.java[diff]
storm-client/src/jvm/org/apache/storm/testing/PythonShellMetricsBolt.java[diff]
storm-client/src/jvm/org/apache/storm/testing/PythonShellMetricsSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestAggregatesCounter.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestConfBolt.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestEventLogSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestEventOrderCheckBolt.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestGlobalCount.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestPlannerSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestWordCounter.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TestWordSpout.java[diff]
storm-client/src/jvm/org/apache/storm/testing/TupleCaptureBolt.java[diff]
storm-client/src/jvm/org/apache/storm/topology/BaseConfigurationDeclarer.java[diff]
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/BasicBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/CheckpointTupleForwarder.java[diff]
storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java[diff]
storm-client/src/jvm/org/apache/storm/topology/IBasicBolt.java[diff]
storm-client/src/jvm/org/apache/storm/topology/IStatefulBolt.java[diff]
storm-client/src/jvm/org/apache/storm/topology/InputDeclarer.java[diff]
storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java[diff]
storm-client/src/jvm/org/apache/storm/topology/PersistentWindowedBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/ResourceDeclarer.java[diff]
storm-client/src/jvm/org/apache/storm/topology/SharedOffHeapWithinNode.java[diff]
storm-client/src/jvm/org/apache/storm/topology/SharedOffHeapWithinWorker.java[diff]
storm-client/src/jvm/org/apache/storm/topology/SharedOnHeap.java[diff]
storm-client/src/jvm/org/apache/storm/topology/StatefulBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java[diff]
storm-client/src/jvm/org/apache/storm/topology/TupleFieldTimestampExtractor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/topology/base/BaseTickTupleAwareRichBolt.java[diff]
storm-client/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java[diff]
storm-client/src/jvm/org/apache/storm/transactional/TransactionAttempt.java[diff]
storm-client/src/jvm/org/apache/storm/trident/JoinOutFieldsMode.java[diff]
storm-client/src/jvm/org/apache/storm/trident/Stream.java[diff]
storm-client/src/jvm/org/apache/storm/trident/TridentState.java[diff]
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java[diff]
storm-client/src/jvm/org/apache/storm/trident/drpc/ReturnResultsReducer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/fluent/ChainedAggregatorDeclarer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/fluent/GroupedStream.java[diff]
storm-client/src/jvm/org/apache/storm/trident/fluent/UniqueIdGen.java[diff]
storm-client/src/jvm/org/apache/storm/trident/graph/Group.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/Assembly.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/BaseOperation.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/DefaultResourceDeclarer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/Filter.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/FlatMapFunction.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/Function.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/ITridentResource.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/MapFunction.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/Operation.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/OperationAwareFlatMapFunction.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/OperationAwareMapFunction.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/TridentCollector.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/TridentMultiReducerContext.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/TridentOperationContext.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/Debug.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/MaxWithComparator.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/MinWithComparator.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/Negate.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CaptureCollector.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ChainedAggregatorImpl.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CombinerAggStateUpdater.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CombinerAggregatorCombineImpl.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CombinerAggregatorInitImpl.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/FilterExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupCollector.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupedAggregator.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupedMultiReducerExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/JoinerMultiReducer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/PreservingFieldsOrderJoinerMultiReducer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ReducerAggStateUpdater.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ReducerAggregatorImpl.java[diff]
storm-client/src/jvm/org/apache/storm/trident/operation/impl/SingleEmitAggregator.java[diff]
storm-client/src/jvm/org/apache/storm/trident/partition/IdentityGrouping.java[diff]
storm-client/src/jvm/org/apache/storm/trident/partition/IndexHashGrouping.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/BridgeReceiver.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/SubtopologyBolt.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AggregateProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AppendCollector.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/EachProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/FreshCollector.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MapProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MultiReducerProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/PartitionPersistProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/ProjectedProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/planner/processor/StateQueryProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/BatchSpoutExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/IBatchID.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/IOpaquePartitionedTridentSpout.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/IPartitionedTridentSpout.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/ITridentSpout.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/OpaquePartitionedTridentSpoutExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/PartitionedTridentSpoutExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchId.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchIdSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutCoordinator.java[diff]
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/JSONNonTransactionalSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/JSONOpaqueSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/JSONTransactionalSerializer.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/State.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/CachedBatchReadsMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/CachedMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/MapCombinerAggStateUpdater.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/MapReducerAggStateUpdater.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/MicroBatchIBackingMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/NonTransactionalMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/OpaqueMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/SnapshottableMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/state/map/TransactionalMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/testing/FeederBatchSpout.java[diff]
storm-client/src/jvm/org/apache/storm/trident/testing/FeederCommitterBatchSpout.java[diff]
storm-client/src/jvm/org/apache/storm/trident/testing/LRUMemoryMapState.java[diff]
storm-client/src/jvm/org/apache/storm/trident/testing/MemoryBackingMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/testing/MemoryMapState.java[diff]
storm-client/src/jvm/org/apache/storm/trident/topology/MasterBatchCoordinator.java[diff]
storm-client/src/jvm/org/apache/storm/trident/topology/TransactionAttempt.java[diff]
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java[diff]
storm-client/src/jvm/org/apache/storm/trident/topology/state/RotatingTransactionalState.java[diff]
storm-client/src/jvm/org/apache/storm/trident/topology/state/TransactionalState.java[diff]
storm-client/src/jvm/org/apache/storm/trident/tuple/ComboList.java[diff]
storm-client/src/jvm/org/apache/storm/trident/tuple/ConsList.java[diff]
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java[diff]
storm-client/src/jvm/org/apache/storm/trident/util/LRUMap.java[diff]
storm-client/src/jvm/org/apache/storm/trident/util/TridentUtils.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/AbstractTridentWindowManager.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/ITridentWindowManager.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/InMemoryWindowsStore.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/TridentBatchTuple.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStateUpdater.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStoreFactory.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/config/BaseWindowConfig.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/config/WindowConfig.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/BaseWindowStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/SlidingCountWindowStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/SlidingDurationWindowStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/TumblingCountWindowStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/TumblingDurationWindowStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/WindowStrategy.java[diff]
storm-client/src/jvm/org/apache/storm/tuple/Fields.java[diff]
storm-client/src/jvm/org/apache/storm/tuple/MessageId.java[diff]
storm-client/src/jvm/org/apache/storm/tuple/Tuple.java[diff]
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java[diff]
storm-client/src/jvm/org/apache/storm/utils/CRC32OutputStream.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java[diff]
storm-client/src/jvm/org/apache/storm/utils/CuratorUtils.java[diff]
storm-client/src/jvm/org/apache/storm/utils/DRPCClient.java[diff]
storm-client/src/jvm/org/apache/storm/utils/InprocMessaging.java[diff]
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java[diff]
storm-client/src/jvm/org/apache/storm/utils/KeyedRoundRobinQueue.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ListDelegate.java[diff]
storm-client/src/jvm/org/apache/storm/utils/LocalState.java[diff]
storm-client/src/jvm/org/apache/storm/utils/MutableObject.java[diff]
storm-client/src/jvm/org/apache/storm/utils/NimbusClient.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ObjectReader.java[diff]
storm-client/src/jvm/org/apache/storm/utils/RotatingMap.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ShellBoltMessageQueue.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ShellCommandRunner.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java[diff]
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java[diff]
storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java[diff]
storm-client/src/jvm/org/apache/storm/utils/StormBoundedExponentialBackoffRetry.java[diff]
storm-client/src/jvm/org/apache/storm/utils/SupervisorClient.java[diff]
storm-client/src/jvm/org/apache/storm/utils/TimeCacheMap.java[diff]
storm-client/src/jvm/org/apache/storm/utils/Utils.java[diff]
storm-client/src/jvm/org/apache/storm/utils/VersionInfo.java[diff]
storm-client/src/jvm/org/apache/storm/utils/VersionedStore.java[diff]
storm-client/src/jvm/org/apache/storm/utils/WindowedTimeThrottler.java[diff]
storm-client/src/jvm/org/apache/storm/utils/WrappedDRPCExecutionException.java[diff]
storm-client/src/jvm/org/apache/storm/utils/WrappedHBExecutionException.java[diff]
storm-client/src/jvm/org/apache/storm/utils/WritableUtils.java[diff]
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java[diff]
storm-client/src/jvm/org/apache/storm/validation/ConfigValidationAnnotations.java[diff]
storm-client/src/jvm/org/apache/storm/validation/ConfigValidationUtils.java[diff]
storm-client/src/jvm/org/apache/storm/validation/NotConf.java[diff]
storm-client/src/jvm/org/apache/storm/validation/Validated.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/CountEvictionPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/CountTriggerPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/EventImpl.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/EvictionContext.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/StatefulWindowManager.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/TimeEvictionPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/TimeTriggerPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/TupleWindowImpl.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountEvictionPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountTriggerPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/WatermarkTimeEvictionPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/WatermarkTimeTriggerPolicy.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/WindowLifecycleListener.java[diff]
storm-client/src/jvm/org/apache/storm/windowing/WindowManager.java[diff]
storm-client/src/jvm/org/apache/storm/zookeeper/ClientZookeeper.java[diff]
storm-client/test/jvm/org/apache/storm/TestConfigValidate.java[diff]
storm-server/src/main/java/org/apache/storm/DaemonConfig.java[diff]
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java[diff]

459 files changed