This is an automated email from the ASF dual-hosted git repository.
reiabreu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
from b9f9b182a Deliver upstream feedback to remote tasks and stop spurious
"No remote destination available" warnings (#9175)
add a2c891a90 Checkstyle auto-fix of storm-client
add 4705aadde Merge master into checkstyle-fix/storm-client-39331264304-1
new 9c737f65f Merge pull request #9184 from
sercuzz8/checkstyle-fix/storm-client-39331264304-1
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
storm-client/src/jvm/org/apache/storm/Config.java | 1477 +++++++++++++-------
.../src/jvm/org/apache/storm/Constants.java | 28 +-
.../src/jvm/org/apache/storm/ILocalCluster.java | 20 +-
.../src/jvm/org/apache/storm/ILocalDRPC.java | 4 +-
.../src/jvm/org/apache/storm/ISubmitterHook.java | 9 +-
.../src/jvm/org/apache/storm/LogWriter.java | 1 -
.../src/jvm/org/apache/storm/StormSubmitter.java | 180 ++-
.../src/jvm/org/apache/storm/StormTimer.java | 43 +-
storm-client/src/jvm/org/apache/storm/Thrift.java | 37 +-
.../storm/annotation/InterfaceStability.java | 9 +-
.../assignments/ILocalAssignmentsBackend.java | 3 +-
.../assignments/InMemoryAssignmentBackend.java | 9 +-
.../LocalAssignmentsBackendFactory.java | 8 +-
.../jvm/org/apache/storm/blobstore/BlobStore.java | 71 +-
.../storm/blobstore/BlobStoreAclHandler.java | 68 +-
.../apache/storm/blobstore/ClientBlobStore.java | 37 +-
.../storm/blobstore/LocalModeClientBlobStore.java | 15 +-
.../apache/storm/blobstore/NimbusBlobStore.java | 33 +-
.../src/jvm/org/apache/storm/bolt/JoinBolt.java | 105 +-
.../storm/callback/DefaultWatcherCallBack.java | 6 +-
.../apache/storm/cluster/ClusterStateContext.java | 3 +-
.../jvm/org/apache/storm/cluster/ClusterUtils.java | 45 +-
.../jvm/org/apache/storm/cluster/DaemonType.java | 19 +-
.../org/apache/storm/cluster/IStateStorage.java | 67 +-
.../apache/storm/cluster/IStormClusterState.java | 51 +-
.../storm/cluster/PaceMakerStateStorage.java | 39 +-
.../cluster/PaceMakerStateStorageFactory.java | 9 +-
.../apache/storm/cluster/StateStorageFactory.java | 3 +-
.../storm/cluster/StormClusterStateImpl.java | 183 ++-
.../org/apache/storm/cluster/ZKStateStorage.java | 37 +-
.../storm/cluster/ZKStateStorageFactory.java | 3 +-
.../storm/container/cgroup/CgroupCenter.java | 5 +-
.../storm/container/cgroup/CgroupCommon.java | 30 +-
.../container/cgroup/CgroupCommonOperation.java | 18 +-
.../storm/container/cgroup/CgroupOperation.java | 19 +-
.../apache/storm/container/cgroup/CgroupUtils.java | 5 +-
.../org/apache/storm/container/cgroup/Device.java | 2 +-
.../apache/storm/container/cgroup/Hierarchy.java | 4 +-
.../apache/storm/container/cgroup/SubSystem.java | 4 +-
.../storm/container/cgroup/SubSystemType.java | 1 -
.../storm/container/cgroup/SystemOperation.java | 5 +-
.../storm/container/cgroup/core/BlkioCore.java | 51 +-
.../storm/container/cgroup/core/CpuCore.java | 30 +-
.../storm/container/cgroup/core/CpuacctCore.java | 6 +-
.../storm/container/cgroup/core/CpusetCore.java | 63 +-
.../storm/container/cgroup/core/DevicesCore.java | 6 +-
.../storm/container/cgroup/core/FreezerCore.java | 6 +-
.../storm/container/cgroup/core/MemoryCore.java | 54 +-
.../storm/container/cgroup/core/NetClsCore.java | 3 +-
.../storm/container/cgroup/core/NetPrioCore.java | 9 +-
.../storm/coordination/BatchBoltExecutor.java | 4 +-
.../storm/coordination/BatchOutputCollector.java | 3 +-
.../coordination/BatchSubtopologyBuilder.java | 25 +-
.../apache/storm/coordination/CoordinatedBolt.java | 38 +-
.../org/apache/storm/coordination/IBatchBolt.java | 3 +-
.../src/jvm/org/apache/storm/daemon/Acker.java | 6 +-
.../org/apache/storm/daemon/GrouperFactory.java | 38 +-
.../jvm/org/apache/storm/daemon/StormCommon.java | 213 +--
.../src/jvm/org/apache/storm/daemon/Task.java | 99 +-
.../apache/storm/daemon/common/FileWatcher.java | 6 +-
.../storm/daemon/metrics/BuiltinMetricsUtil.java | 12 +-
.../storm/daemon/metrics/ClientMetricsUtils.java | 4 +-
.../storm/daemon/supervisor/AdvancedFSOps.java | 43 +-
.../daemon/supervisor/ClientSupervisorUtils.java | 34 +-
.../storm/daemon/supervisor/IAdvancedFSOps.java | 14 +-
.../storm/daemon/worker/BackPressureTracker.java | 28 +-
.../storm/daemon/worker/LogConfigManager.java | 12 +-
.../jvm/org/apache/storm/daemon/worker/Worker.java | 275 ++--
.../apache/storm/daemon/worker/WorkerState.java | 248 ++--
.../apache/storm/daemon/worker/WorkerTransfer.java | 31 +-
.../storm/dependency/DependencyBlobStoreUtils.java | 9 +-
.../storm/dependency/DependencyUploader.java | 31 +-
.../apache/storm/drpc/DRPCInvocationsClient.java | 9 +-
.../src/jvm/org/apache/storm/drpc/DRPCSpout.java | 68 +-
.../src/jvm/org/apache/storm/drpc/JoinResult.java | 4 +-
.../jvm/org/apache/storm/drpc/KeyedFairBolt.java | 6 +-
.../storm/drpc/LinearDRPCTopologyBuilder.java | 32 +-
.../jvm/org/apache/storm/drpc/PrepareRequest.java | 1 -
.../jvm/org/apache/storm/drpc/ReturnResults.java | 8 +-
.../org/apache/storm/executor/ChildEwmaStats.java | 20 +-
.../apache/storm/executor/EwmaFeedbackRecord.java | 3 +-
.../jvm/org/apache/storm/executor/Executor.java | 203 +--
.../apache/storm/executor/ExecutorShutdown.java | 26 +-
.../apache/storm/executor/ExecutorTransfer.java | 42 +-
.../org/apache/storm/executor/LocalExecutor.java | 11 +-
.../jvm/org/apache/storm/executor/TupleInfo.java | 2 +-
.../apache/storm/executor/bolt/BoltExecutor.java | 31 +-
.../executor/bolt/BoltOutputCollectorImpl.java | 29 +-
.../apache/storm/executor/error/ReportError.java | 11 +-
.../storm/executor/error/ReportErrorAndDie.java | 2 +-
.../apache/storm/executor/spout/SpoutExecutor.java | 71 +-
.../executor/spout/SpoutOutputCollectorImpl.java | 28 +-
.../storm/grouping/CustomStreamGrouping.java | 6 +-
.../storm/grouping/JitterAwareStreamGrouping.java | 48 +-
.../src/jvm/org/apache/storm/grouping/Load.java | 14 +-
.../storm/grouping/LoadAwareShuffleGrouping.java | 63 +-
.../jvm/org/apache/storm/grouping/LoadMapping.java | 6 +-
.../apache/storm/grouping/PartialKeyGrouping.java | 45 +-
.../org/apache/storm/grouping/ShuffleGrouping.java | 4 +-
.../jvm/org/apache/storm/hooks/BaseWorkerHook.java | 5 +-
.../jvm/org/apache/storm/hooks/IWorkerHook.java | 20 +-
.../apache/storm/hooks/SubmitterHookException.java | 3 +-
.../org/apache/storm/hooks/info/BoltAckInfo.java | 1 -
.../apache/storm/hooks/info/BoltExecuteInfo.java | 1 -
.../org/apache/storm/hooks/info/BoltFailInfo.java | 1 -
.../org/apache/storm/hooks/info/SpoutAckInfo.java | 1 -
.../org/apache/storm/hooks/info/SpoutFailInfo.java | 1 -
.../apache/storm/lambda/LambdaBiConsumerBolt.java | 3 +-
.../jvm/org/apache/storm/lambda/LambdaSpout.java | 3 +-
.../storm/messaging/ConnectionWithStatus.java | 11 +-
.../messaging/DeserializingConnectionCallback.java | 70 +-
.../messaging/FatalDeserializationException.java | 6 +-
.../org/apache/storm/messaging/IConnection.java | 5 +-
.../jvm/org/apache/storm/messaging/IContext.java | 9 +-
.../apache/storm/messaging/TransportFactory.java | 19 +-
.../org/apache/storm/messaging/local/Context.java | 33 +-
.../storm/messaging/netty/BackPressureStatus.java | 9 +-
.../messaging/netty/BackPressureStatusEncoder.java | 5 +-
.../org/apache/storm/messaging/netty/Client.java | 135 +-
.../org/apache/storm/messaging/netty/Context.java | 29 +-
.../storm/messaging/netty/ControlMessage.java | 3 +-
.../storm/messaging/netty/INettySerializable.java | 1 +
.../org/apache/storm/messaging/netty/IServer.java | 3 +-
.../messaging/netty/KerberosSaslClientHandler.java | 45 +-
.../messaging/netty/KerberosSaslNettyClient.java | 25 +-
.../messaging/netty/KerberosSaslNettyServer.java | 27 +-
.../messaging/netty/KerberosSaslServerHandler.java | 39 +-
.../org/apache/storm/messaging/netty/Login.java | 133 +-
.../apache/storm/messaging/netty/MessageBatch.java | 13 +-
.../storm/messaging/netty/MessageDecoder.java | 17 +-
.../messaging/netty/NettyRenameThreadFactory.java | 3 +-
.../netty/NettySerializableMessageEncoder.java | 16 +-
.../storm/messaging/netty/NettyTlsUtils.java | 54 +-
.../netty/NettyUncaughtExceptionHandler.java | 3 +-
.../storm/messaging/netty/SaslMessageToken.java | 5 +-
.../storm/messaging/netty/SaslNettyClient.java | 35 +-
.../messaging/netty/SaslNettyClientState.java | 3 +-
.../storm/messaging/netty/SaslNettyServer.java | 31 +-
.../messaging/netty/SaslNettyServerState.java | 3 +-
.../messaging/netty/SaslStormClientHandler.java | 50 +-
.../netty/SaslStormServerAuthorizeHandler.java | 25 +-
.../messaging/netty/SaslStormServerHandler.java | 43 +-
.../apache/storm/messaging/netty/SaslUtils.java | 6 +-
.../org/apache/storm/messaging/netty/Server.java | 76 +-
.../storm/messaging/netty/StormClientHandler.java | 25 +-
.../netty/StormClientPipelineFactory.java | 15 +-
.../storm/messaging/netty/StormServerHandler.java | 18 +-
.../netty/StormServerPipelineFactory.java | 12 +-
.../org/apache/storm/metric/EventLoggerBolt.java | 29 +-
.../apache/storm/metric/FileBasedEventLogger.java | 12 +-
.../jvm/org/apache/storm/metric/IEventLogger.java | 11 +-
.../storm/metric/LoggingMetricsConsumer.java | 19 +-
.../apache/storm/metric/MetricsConsumerBolt.java | 24 +-
.../jvm/org/apache/storm/metric/SystemBolt.java | 25 +-
.../jvm/org/apache/storm/metric/api/IMetric.java | 8 +-
.../apache/storm/metric/api/IMetricsConsumer.java | 10 +-
.../org/apache/storm/metric/api/MeanReducer.java | 4 +-
.../storm/metric/api/rpc/CountShellMetric.java | 3 +-
.../org/apache/storm/metric/cgroup/CGroupCpu.java | 5 +-
.../storm/metric/cgroup/CGroupCpuGuarantee.java | 5 +-
.../cgroup/CGroupCpuGuaranteeByCfsQuota.java | 6 +-
.../storm/metric/cgroup/CGroupMemoryLimit.java | 2 +-
.../storm/metric/cgroup/CGroupMetricsBase.java | 38 +-
.../storm/metric/filter/FilterByMetricName.java | 13 +-
.../apache/storm/metric/internal/CountStat.java | 22 +-
.../apache/storm/metric/internal/LatencyStat.java | 31 +-
.../storm/metric/internal/MultiCountStat.java | 7 +-
.../apache/storm/metric/internal/RateTracker.java | 19 +-
.../storm/metric/util/DataPointExpander.java | 6 +-
.../apache/storm/metrics2/DimensionalReporter.java | 25 +-
.../jvm/org/apache/storm/metrics2/EwmaGauge.java | 1 -
.../jvm/org/apache/storm/metrics2/RateCounter.java | 13 +-
.../apache/storm/metrics2/StormMetricRegistry.java | 170 ++-
.../storm/metrics2/TaskMetricDimensions.java | 3 +-
.../org/apache/storm/metrics2/TaskMetricRepo.java | 9 +-
.../jvm/org/apache/storm/metrics2/TaskMetrics.java | 17 +-
.../storm/metrics2/cgroup/CGroupCpuGuarantee.java | 3 +-
.../cgroup/CGroupCpuGuaranteeByCfsQuota.java | 6 +-
.../storm/metrics2/cgroup/CGroupCpuStat.java | 1 -
.../storm/metrics2/cgroup/CGroupMemoryLimit.java | 2 +-
.../storm/metrics2/cgroup/CGroupMetricsBase.java | 34 +-
.../apache/storm/metrics2/filters/RegexFilter.java | 1 -
.../storm/metrics2/filters/StormMetricsFilter.java | 3 +-
.../metrics2/reporters/ConsoleStormReporter.java | 17 +-
.../storm/metrics2/reporters/CsvStormReporter.java | 11 +-
.../metrics2/reporters/GraphiteStormReporter.java | 8 +-
.../storm/metrics2/reporters/JmxStormReporter.java | 10 +-
.../metrics2/reporters/ScheduledStormReporter.java | 7 +-
.../storm/metrics2/reporters/StormReporter.java | 7 +-
.../jvm/org/apache/storm/multilang/BoltMsg.java | 9 +-
.../org/apache/storm/multilang/ISerializer.java | 5 +-
.../org/apache/storm/multilang/JsonSerializer.java | 9 +-
.../jvm/org/apache/storm/multilang/ShellMsg.java | 13 +-
.../jvm/org/apache/storm/multilang/SpoutMsg.java | 9 +-
.../AbstractDNSToSwitchMapping.java | 25 +-
.../networktopography/DNSToSwitchMapping.java | 18 +-
.../DefaultRackDNSToSwitchMapping.java | 8 +-
.../org/apache/storm/nimbus/ILeaderElector.java | 18 +-
.../jvm/org/apache/storm/nimbus/NimbusInfo.java | 18 +-
.../apache/storm/pacemaker/PacemakerClient.java | 52 +-
.../storm/pacemaker/PacemakerClientHandler.java | 8 +-
.../storm/pacemaker/PacemakerClientPool.java | 9 +-
.../pacemaker/PacemakerConnectionException.java | 6 +-
.../storm/pacemaker/codec/ThriftDecoder.java | 22 +-
.../storm/pacemaker/codec/ThriftEncoder.java | 15 +-
.../pacemaker/codec/ThriftNettyClientCodec.java | 16 +-
.../jvm/org/apache/storm/policy/IWaitStrategy.java | 10 +-
.../org/apache/storm/policy/WaitStrategyPark.java | 9 +-
.../storm/policy/WaitStrategyProgressive.java | 42 +-
.../storm/security/INimbusCredentialPlugin.java | 24 +-
.../org/apache/storm/security/auth/AutoSSL.java | 17 +-
.../storm/security/auth/ClientAuthUtils.java | 92 +-
.../security/auth/DefaultPrincipalToLocal.java | 3 +-
.../storm/security/auth/FixedGroupsMapping.java | 4 +-
.../apache/storm/security/auth/IAuthorizer.java | 3 +-
.../storm/security/auth/IAutoCredentials.java | 7 +-
.../storm/security/auth/ICredentialsRenewer.java | 3 +-
.../auth/IGroupMappingServiceProvider.java | 3 +-
.../storm/security/auth/IPrincipalToLocal.java | 3 +-
.../storm/security/auth/ITransportPlugin.java | 11 +-
.../security/auth/KerberosPrincipalToLocal.java | 2 +-
.../storm/security/auth/MultiThriftServer.java | 14 +-
.../org/apache/storm/security/auth/ReqContext.java | 15 +-
.../security/auth/ShellBasedGroupsMapping.java | 16 +-
.../storm/security/auth/SimpleTransportPlugin.java | 23 +-
.../apache/storm/security/auth/SubjectCompat.java | 13 +-
.../storm/security/auth/TBackoffConnect.java | 13 +-
.../apache/storm/security/auth/ThriftClient.java | 56 +-
.../storm/security/auth/ThriftConnectionType.java | 35 +-
.../apache/storm/security/auth/ThriftServer.java | 14 +-
.../auth/X509CertOrKerberosPrincipalToLocal.java | 15 +-
.../security/auth/X509CertPrincipalToLocal.java | 11 +-
.../auth/authorizer/DRPCAuthorizerBase.java | 9 +-
.../auth/authorizer/DRPCSimpleACLAuthorizer.java | 24 +-
.../auth/authorizer/ImpersonationAuthorizer.java | 38 +-
.../auth/authorizer/SimpleACLAuthorizer.java | 101 +-
.../auth/authorizer/SimpleWhitelistAuthorizer.java | 3 +-
.../authorizer/SupervisorSimpleACLAuthorizer.java | 26 +-
.../auth/digest/DigestSaslTransportPlugin.java | 35 +-
.../security/auth/digest/JassPasswordProvider.java | 17 +-
.../storm/security/auth/kerberos/AutoTGT.java | 54 +-
.../auth/kerberos/AutoTGTKrb5LoginModule.java | 4 +-
.../auth/kerberos/ClientCallbackHandler.java | 35 +-
.../auth/kerberos/KerberosSaslTransportPlugin.java | 128 +-
.../auth/kerberos/ServerCallbackHandler.java | 33 +-
.../auth/plain/PlainClientCallbackHandler.java | 3 +-
.../auth/plain/PlainSaslTransportPlugin.java | 36 +-
.../storm/security/auth/plain/SaslPlainServer.java | 18 +-
.../storm/security/auth/sasl/PasswordProvider.java | 12 +-
.../security/auth/sasl/SaslTransportPlugin.java | 31 +-
.../auth/sasl/SimpleSaslServerCallbackHandler.java | 56 +-
.../auth/tls/ReloadableTsslTransportFactory.java | 23 +-
.../auth/tls/ReloadableX509KeyManager.java | 25 +-
.../auth/tls/ReloadableX509TrustManager.java | 31 +-
.../security/auth/tls/TlsTransportPlugin.java | 27 +-
.../auth/workertoken/WorkerTokenAuthorizer.java | 30 +-
.../WorkerTokenClientCallbackHandler.java | 17 +-
.../auth/workertoken/WorkerTokenSigner.java | 15 +-
.../serialization/BlowfishTupleSerializer.java | 23 +-
.../storm/serialization/DefaultKryoFactory.java | 16 +-
.../GzipBridgeThriftSerializationDelegate.java | 8 +-
.../serialization/GzipSerializationDelegate.java | 9 +-
.../GzipThriftSerializationDelegate.java | 9 +-
.../apache/storm/serialization/IKryoDecorator.java | 2 +
.../storm/serialization/ITupleSerializer.java | 1 -
.../storm/serialization/KryoTupleDeserializer.java | 39 +-
.../storm/serialization/KryoTupleSerializer.java | 15 +-
.../serialization/SerializableSerializer.java | 28 +-
.../storm/serialization/SerializationFactory.java | 41 +-
.../storm/serialization/SerializationRegister.java | 6 +-
.../TupleDeserializationException.java | 3 +-
.../ZstdBridgeThriftSerializationDelegate.java | 9 +-
.../ZstdThriftSerializationDelegate.java | 15 +-
.../serialization/types/ArrayListSerializer.java | 2 -
.../serialization/types/HashMapSerializer.java | 5 +-
.../serialization/types/HashSetSerializer.java | 2 -
.../types/ListDelegateSerializer.java | 5 +-
.../org/apache/storm/spout/CheckPointState.java | 29 +-
.../org/apache/storm/spout/CheckpointSpout.java | 21 +-
.../src/jvm/org/apache/storm/spout/ISpout.java | 75 +-
.../apache/storm/spout/ISpoutOutputCollector.java | 3 +-
.../src/jvm/org/apache/storm/spout/RawScheme.java | 2 +-
.../src/jvm/org/apache/storm/spout/Scheme.java | 1 -
.../src/jvm/org/apache/storm/spout/ShellSpout.java | 55 +-
.../apache/storm/spout/SpoutOutputCollector.java | 75 +-
.../storm/state/BaseBinaryStateIterator.java | 8 +-
.../org/apache/storm/state/BaseStateIterator.java | 7 +-
.../apache/storm/state/DefaultStateEncoder.java | 11 +-
.../apache/storm/state/DefaultStateSerializer.java | 31 +-
.../src/jvm/org/apache/storm/state/State.java | 15 +-
.../jvm/org/apache/storm/state/StateFactory.java | 9 +-
.../jvm/org/apache/storm/state/StateProvider.java | 3 +-
.../storm/state/SynchronizeOutputCollector.java | 1 -
.../org/apache/storm/stats/BoltExecutorStats.java | 31 +-
.../org/apache/storm/stats/ClientStatsUtil.java | 12 +-
.../org/apache/storm/stats/SpoutExecutorStats.java | 2 +-
.../jvm/org/apache/storm/streams/GroupingInfo.java | 15 +-
.../src/jvm/org/apache/storm/streams/Node.java | 9 +-
.../jvm/org/apache/storm/streams/PairStream.java | 184 ++-
.../org/apache/storm/streams/PartitionNode.java | 3 +-
.../org/apache/storm/streams/ProcessorBolt.java | 4 +-
.../storm/streams/ProcessorBoltDelegate.java | 40 +-
.../org/apache/storm/streams/ProcessorNode.java | 3 +-
.../org/apache/storm/streams/RefCountedTuple.java | 3 +-
.../storm/streams/StatefulProcessorBolt.java | 6 +-
.../src/jvm/org/apache/storm/streams/Stream.java | 182 ++-
.../org/apache/storm/streams/StreamBuilder.java | 102 +-
.../jvm/org/apache/storm/streams/StreamState.java | 3 +-
.../storm/streams/WindowedProcessorBolt.java | 3 +-
.../storm/streams/operations/BiFunction.java | 2 +-
.../streams/operations/CombinerAggregator.java | 9 +-
.../streams/operations/PairFlatMapFunction.java | 3 +-
.../storm/streams/operations/PairValueJoiner.java | 3 +-
.../apache/storm/streams/operations/Reducer.java | 3 +-
.../storm/streams/operations/StateUpdater.java | 6 +-
.../operations/mappers/PairValueMapper.java | 3 +-
.../operations/mappers/TupleValueMappers.java | 176 +--
.../streams/operations/mappers/ValuesMapper.java | 3 +-
.../storm/streams/processors/BaseProcessor.java | 18 +-
.../storm/streams/processors/BatchProcessor.java | 3 +-
.../processors/ChainedProcessorContext.java | 3 +-
.../streams/processors/CoGroupByKeyProcessor.java | 8 +-
.../processors/EmittingProcessorContext.java | 9 +-
.../processors/ForwardingProcessorContext.java | 3 +-
.../storm/streams/processors/JoinProcessor.java | 9 +-
.../apache/storm/streams/processors/Processor.java | 6 +-
.../storm/streams/processors/ProcessorContext.java | 3 +-
.../org/apache/storm/streams/tuple/Tuple10.java | 3 +-
.../jvm/org/apache/storm/streams/tuple/Tuple6.java | 3 +-
.../jvm/org/apache/storm/streams/tuple/Tuple7.java | 3 +-
.../jvm/org/apache/storm/streams/tuple/Tuple8.java | 6 +-
.../jvm/org/apache/storm/streams/tuple/Tuple9.java | 3 +-
.../apache/storm/streams/windowing/BaseWindow.java | 6 +-
.../storm/streams/windowing/SlidingWindows.java | 33 +-
.../storm/streams/windowing/TumblingWindows.java | 27 +-
.../org/apache/storm/streams/windowing/Window.java | 12 +-
.../apache/storm/task/GeneralTopologyContext.java | 15 +-
.../src/jvm/org/apache/storm/task/IBolt.java | 63 +-
.../jvm/org/apache/storm/task/IMetricsContext.java | 6 +-
.../jvm/org/apache/storm/task/OutputCollector.java | 99 +-
.../src/jvm/org/apache/storm/task/ShellBolt.java | 77 +-
.../jvm/org/apache/storm/task/TopologyContext.java | 68 +-
.../apache/storm/task/WorkerTopologyContext.java | 78 +-
.../org/apache/storm/task/WorkerUserContext.java | 36 +-
.../testing/AlternateRackDNSToSwitchMapping.java | 5 +-
.../jvm/org/apache/storm/testing/BoltTracker.java | 1 -
.../org/apache/storm/testing/CompletableSpout.java | 5 +-
.../jvm/org/apache/storm/testing/FeederSpout.java | 4 +-
.../org/apache/storm/testing/FixedTupleSpout.java | 3 +-
.../storm/testing/ForwardingMetricsConsumer.java | 6 +-
.../org/apache/storm/testing/MkClusterParam.java | 12 +-
.../org/apache/storm/testing/MockedSources.java | 6 +-
.../jvm/org/apache/storm/testing/NGrouping.java | 3 +-
.../apache/storm/testing/NonRichBoltTracker.java | 4 +-
.../org/apache/storm/testing/PrepareBatchBolt.java | 2 -
.../storm/testing/PythonShellMetricsBolt.java | 3 +-
.../storm/testing/PythonShellMetricsSpout.java | 3 +-
.../storm/testing/SingleUserSimpleTransport.java | 1 -
.../jvm/org/apache/storm/testing/SpoutTracker.java | 8 +-
.../storm/testing/TestAggregatesCounter.java | 4 +-
.../jvm/org/apache/storm/testing/TestConfBolt.java | 1 -
.../apache/storm/testing/TestEventLogSpout.java | 3 +-
.../storm/testing/TestEventOrderCheckBolt.java | 6 +-
.../org/apache/storm/testing/TestGlobalCount.java | 4 +-
.../org/apache/storm/testing/TestPlannerBolt.java | 4 +-
.../org/apache/storm/testing/TestPlannerSpout.java | 5 +-
.../org/apache/storm/testing/TestWordCounter.java | 1 -
.../org/apache/storm/testing/TestWordSpout.java | 6 +-
.../src/jvm/org/apache/storm/testing/TmpPath.java | 2 +-
.../org/apache/storm/testing/TupleCaptureBolt.java | 29 +-
.../storm/topology/BaseConfigurationDeclarer.java | 8 +-
.../storm/topology/BaseStatefulBoltExecutor.java | 27 +-
.../apache/storm/topology/BasicBoltExecutor.java | 4 +-
.../storm/topology/BasicOutputCollector.java | 7 +-
.../storm/topology/CheckpointTupleForwarder.java | 14 +-
.../topology/ComponentConfigurationDeclarer.java | 4 +-
.../storm/topology/ConfigurableTopology.java | 11 +-
.../jvm/org/apache/storm/topology/IComponent.java | 12 +-
.../jvm/org/apache/storm/topology/IRichBolt.java | 3 +-
.../jvm/org/apache/storm/topology/IRichSpout.java | 3 +-
.../org/apache/storm/topology/IRichStateSpout.java | 1 -
.../org/apache/storm/topology/IStatefulBolt.java | 9 +-
.../apache/storm/topology/IStatefulComponent.java | 18 +-
.../storm/topology/IStatefulWindowedBolt.java | 7 +-
.../org/apache/storm/topology/IWindowedBolt.java | 9 +-
.../org/apache/storm/topology/InputDeclarer.java | 31 +-
.../storm/topology/OutputFieldsDeclarer.java | 1 -
.../apache/storm/topology/OutputFieldsGetter.java | 1 -
.../topology/PersistentWindowedBoltExecutor.java | 60 +-
.../apache/storm/topology/ResourceDeclarer.java | 6 +-
.../storm/topology/StatefulBoltExecutor.java | 24 +-
.../topology/StatefulWindowedBoltExecutor.java | 52 +-
.../org/apache/storm/topology/TopologyBuilder.java | 333 +++--
.../storm/topology/WindowedBoltExecutor.java | 114 +-
.../storm/topology/base/BaseStatefulBolt.java | 3 +-
.../topology/base/BaseStatefulWindowedBolt.java | 15 +-
.../topology/base/BaseTickTupleAwareRichBolt.java | 6 +-
.../storm/topology/base/BaseWindowedBolt.java | 36 +-
.../storm/transactional/TransactionAttempt.java | 1 -
.../apache/storm/trident/JoinOutFieldsMode.java | 9 +-
.../src/jvm/org/apache/storm/trident/Stream.java | 263 ++--
.../jvm/org/apache/storm/trident/TridentState.java | 1 -
.../org/apache/storm/trident/TridentTopology.java | 222 +--
.../storm/trident/drpc/ReturnResultsReducer.java | 3 +-
.../trident/fluent/ChainedAggregatorDeclarer.java | 49 +-
.../fluent/ChainedFullAggregatorDeclarer.java | 9 +-
.../fluent/ChainedPartitionAggregatorDeclarer.java | 15 +-
.../trident/fluent/GlobalAggregationScheme.java | 1 -
.../apache/storm/trident/fluent/GroupedStream.java | 70 +-
.../storm/trident/fluent/IAggregatableStream.java | 3 +-
.../jvm/org/apache/storm/trident/graph/Group.java | 39 +-
.../apache/storm/trident/operation/Assembly.java | 4 +-
.../storm/trident/operation/BaseMultiReducer.java | 1 -
.../storm/trident/operation/BaseOperation.java | 3 +-
.../apache/storm/trident/operation/Consumer.java | 3 +-
.../trident/operation/DefaultResourceDeclarer.java | 13 +-
.../org/apache/storm/trident/operation/Filter.java | 9 +-
.../apache/storm/trident/operation/Function.java | 42 +-
.../trident/operation/GroupedMultiReducer.java | 4 +-
.../storm/trident/operation/ITridentResource.java | 5 +-
.../storm/trident/operation/MultiReducer.java | 1 -
.../apache/storm/trident/operation/Operation.java | 12 +-
.../operation/OperationAwareFlatMapFunction.java | 3 +-
.../operation/OperationAwareMapFunction.java | 3 +-
.../storm/trident/operation/TridentCollector.java | 10 +-
.../operation/TridentMultiReducerContext.java | 1 -
.../trident/operation/TridentOperationContext.java | 5 +-
.../operation/builtin/ComparisonAggregator.java | 14 +-
.../storm/trident/operation/builtin/Count.java | 1 -
.../storm/trident/operation/builtin/Debug.java | 3 +-
.../storm/trident/operation/builtin/Equals.java | 1 -
.../trident/operation/builtin/FilterNull.java | 3 +-
.../storm/trident/operation/builtin/FirstN.java | 5 +-
.../storm/trident/operation/builtin/MapGet.java | 1 -
.../storm/trident/operation/builtin/Max.java | 3 +-
.../storm/trident/operation/builtin/Min.java | 3 +-
.../operation/builtin/MinWithComparator.java | 3 +-
.../storm/trident/operation/builtin/Negate.java | 12 +-
.../storm/trident/operation/builtin/Sum.java | 1 -
.../operation/builtin/TupleCollectionGet.java | 3 +-
.../operation/impl/ChainedAggregatorImpl.java | 5 +-
.../trident/operation/impl/ChainedResult.java | 3 +-
.../operation/impl/CombinerAggStateUpdater.java | 7 +-
.../trident/operation/impl/GroupedAggregator.java | 2 +-
.../impl/GroupedMultiReducerExecutor.java | 10 +-
.../operation/impl/IdentityMultiReducer.java | 1 -
.../trident/operation/impl/JoinerMultiReducer.java | 19 +-
.../PreservingFieldsOrderJoinerMultiReducer.java | 28 +-
.../operation/impl/ReducerAggStateUpdater.java | 4 +-
.../operation/impl/SingleEmitAggregator.java | 6 +-
.../storm/trident/partition/GlobalGrouping.java | 3 +-
.../storm/trident/partition/IdentityGrouping.java | 10 +-
.../storm/trident/partition/IndexHashGrouping.java | 3 +-
.../storm/trident/planner/BridgeReceiver.java | 1 -
.../storm/trident/planner/PartitionNode.java | 3 +-
.../storm/trident/planner/ProcessorNode.java | 6 +-
.../apache/storm/trident/planner/SpoutNode.java | 6 +-
.../storm/trident/planner/SubtopologyBolt.java | 42 +-
.../storm/trident/planner/TupleReceiver.java | 3 +-
.../planner/processor/AggregateProcessor.java | 10 +-
.../trident/planner/processor/AppendCollector.java | 4 +-
.../trident/planner/processor/EachProcessor.java | 5 +-
.../trident/planner/processor/FreshCollector.java | 1 -
.../trident/planner/processor/MapProcessor.java | 3 +-
.../planner/processor/MultiReducerProcessor.java | 10 +-
.../processor/PartitionPersistProcessor.java | 7 +-
.../planner/processor/ProjectedProcessor.java | 7 +-
.../planner/processor/StateQueryProcessor.java | 10 +-
.../trident/planner/processor/TridentContext.java | 3 +-
.../storm/trident/spout/BatchSpoutExecutor.java | 9 +-
.../spout/IOpaquePartitionedTridentSpout.java | 50 +-
.../trident/spout/IPartitionedTridentSpout.java | 47 +-
.../apache/storm/trident/spout/ITridentSpout.java | 51 +-
.../OpaquePartitionedTridentSpoutExecutor.java | 55 +-
.../spout/PartitionedTridentSpoutExecutor.java | 38 +-
.../trident/spout/RichSpoutBatchExecutor.java | 14 +-
.../trident/spout/RichSpoutBatchIdSerializer.java | 1 -
.../trident/spout/RichSpoutBatchTriggerer.java | 10 +-
.../trident/spout/TridentSpoutCoordinator.java | 5 +-
.../storm/trident/spout/TridentSpoutExecutor.java | 4 +-
.../storm/trident/state/BaseQueryFunction.java | 1 -
.../storm/trident/state/BaseStateUpdater.java | 1 -
.../state/JSONNonTransactionalSerializer.java | 1 -
.../apache/storm/trident/state/OpaqueValue.java | 6 +-
.../apache/storm/trident/state/ReadOnlyState.java | 6 +-
.../org/apache/storm/trident/state/Serializer.java | 1 -
.../jvm/org/apache/storm/trident/state/State.java | 15 +-
.../apache/storm/trident/state/StateFactory.java | 3 +-
.../org/apache/storm/trident/state/StateSpec.java | 1 -
.../apache/storm/trident/state/StateUpdater.java | 4 +-
.../trident/state/map/CachedBatchReadsMap.java | 2 -
.../apache/storm/trident/state/map/CachedMap.java | 3 +-
.../storm/trident/state/map/IBackingMap.java | 1 -
.../state/map/MapCombinerAggStateUpdater.java | 10 +-
.../state/map/MapReducerAggStateUpdater.java | 7 +-
.../trident/state/map/MicroBatchIBackingMap.java | 1 -
.../trident/state/map/NonTransactionalMap.java | 1 -
.../apache/storm/trident/state/map/OpaqueMap.java | 1 -
.../storm/trident/state/map/SnapshottableMap.java | 1 -
.../storm/trident/state/map/TransactionalMap.java | 1 -
.../trident/state/snapshot/Snapshottable.java | 1 -
.../storm/trident/testing/CountAsAggregator.java | 1 -
.../storm/trident/testing/FeederBatchSpout.java | 23 +-
.../trident/testing/FeederCommitterBatchSpout.java | 8 +-
.../storm/trident/testing/FixedBatchSpout.java | 1 -
.../storm/trident/testing/LRUMemoryMapState.java | 9 +-
.../storm/trident/testing/MemoryMapState.java | 12 +-
.../apache/storm/trident/topology/BatchInfo.java | 1 -
.../trident/topology/MasterBatchCoordinator.java | 30 +-
.../storm/trident/topology/TransactionAttempt.java | 2 -
.../trident/topology/TridentBoltExecutor.java | 35 +-
.../trident/topology/TridentTopologyBuilder.java | 102 +-
.../topology/state/RotatingTransactionalState.java | 3 +-
.../topology/state/TestTransactionalState.java | 2 +-
.../trident/topology/state/TransactionalState.java | 38 +-
.../org/apache/storm/trident/tuple/ComboList.java | 6 +-
.../storm/trident/tuple/TridentTupleView.java | 18 +-
.../apache/storm/trident/tuple/ValuePointer.java | 3 +-
.../org/apache/storm/trident/util/IndexedEdge.java | 1 -
.../apache/storm/trident/util/TridentUtils.java | 1 -
.../windowing/AbstractTridentWindowManager.java | 20 +-
.../trident/windowing/ITridentWindowManager.java | 3 +-
.../windowing/InMemoryTridentWindowManager.java | 3 +-
.../trident/windowing/InMemoryWindowsStore.java | 4 +-
.../windowing/InMemoryWindowsStoreFactory.java | 6 +-
.../windowing/StoreBasedTridentWindowManager.java | 42 +-
.../storm/trident/windowing/TridentBatchTuple.java | 3 +-
.../trident/windowing/WindowKryoSerializer.java | 6 +-
.../trident/windowing/WindowTridentProcessor.java | 50 +-
.../trident/windowing/WindowsStateFactory.java | 3 +-
.../trident/windowing/WindowsStateUpdater.java | 23 +-
.../storm/trident/windowing/WindowsStore.java | 3 +-
.../trident/windowing/WindowsStoreFactory.java | 3 +-
.../trident/windowing/config/BaseWindowConfig.java | 3 +-
.../windowing/config/SlidingDurationWindow.java | 3 +-
.../strategy/SlidingCountWindowStrategy.java | 6 +-
.../strategy/SlidingDurationWindowStrategy.java | 6 +-
.../strategy/TumblingCountWindowStrategy.java | 6 +-
.../strategy/TumblingDurationWindowStrategy.java | 6 +-
.../trident/windowing/strategy/WindowStrategy.java | 3 +-
.../jvm/org/apache/storm/tuple/AddressedTuple.java | 8 +-
.../jvm/org/apache/storm/tuple/DetachedTuple.java | 21 +-
.../src/jvm/org/apache/storm/tuple/Fields.java | 9 +-
.../src/jvm/org/apache/storm/tuple/ITuple.java | 30 +-
.../src/jvm/org/apache/storm/tuple/Tuple.java | 12 +-
.../src/jvm/org/apache/storm/tuple/TupleImpl.java | 11 +-
.../jvm/org/apache/storm/utils/BatchHelper.java | 2 +-
.../apache/storm/utils/BufferFileInputStream.java | 1 -
.../jvm/org/apache/storm/utils/ConfigUtils.java | 107 +-
.../jvm/org/apache/storm/utils/CuratorUtils.java | 52 +-
.../src/jvm/org/apache/storm/utils/DRPCClient.java | 26 +-
.../apache/storm/utils/DefaultShellLogHandler.java | 5 +-
.../storm/utils/DisallowedStrategyException.java | 9 +-
.../storm/utils/ExtendedThreadPoolExecutor.java | 15 +-
.../org/apache/storm/utils/HadoopLoginUtil.java | 17 +-
.../src/jvm/org/apache/storm/utils/IPredicate.java | 3 +-
.../jvm/org/apache/storm/utils/IVersionInfo.java | 6 +
.../org/apache/storm/utils/InprocMessaging.java | 5 +-
.../src/jvm/org/apache/storm/utils/JCQueue.java | 178 ++-
.../jvm/org/apache/storm/utils/JCQueueMetrics.java | 39 +-
.../org/apache/storm/utils/KeyStreamRandom.java | 24 +-
.../src/jvm/org/apache/storm/utils/LocalState.java | 21 +-
.../jvm/org/apache/storm/utils/NimbusClient.java | 90 +-
.../storm/utils/NimbusLeaderNotFoundException.java | 3 +-
.../jvm/org/apache/storm/utils/ObjectReader.java | 1 +
.../org/apache/storm/utils/ReflectionUtils.java | 35 +-
.../apache/storm/utils/RegisteredGlobalState.java | 6 +-
.../jvm/org/apache/storm/utils/RotatingMap.java | 11 +-
.../jvm/org/apache/storm/utils/SecurityUtils.java | 3 +-
.../apache/storm/utils/ShellBoltMessageQueue.java | 13 +-
.../org/apache/storm/utils/ShellCommandRunner.java | 14 +-
.../apache/storm/utils/ShellCommandRunnerImpl.java | 5 +-
.../org/apache/storm/utils/ShellLogHandler.java | 3 +-
.../jvm/org/apache/storm/utils/ShellProcess.java | 26 +-
.../src/jvm/org/apache/storm/utils/ShellUtils.java | 77 +-
.../jvm/org/apache/storm/utils/SimpleVersion.java | 4 +-
.../utils/StormBoundedExponentialBackoffRetry.java | 24 +-
.../org/apache/storm/utils/SupervisorClient.java | 39 +-
.../apache/storm/utils/ThriftTopologyUtils.java | 3 +-
.../src/jvm/org/apache/storm/utils/Time.java | 33 +-
.../jvm/org/apache/storm/utils/TimeCacheMap.java | 12 +-
.../org/apache/storm/utils/TransferDrainer.java | 6 +-
.../src/jvm/org/apache/storm/utils/TupleUtils.java | 7 +-
.../src/jvm/org/apache/storm/utils/Utils.java | 397 ++++--
.../jvm/org/apache/storm/utils/VersionInfo.java | 40 +-
.../jvm/org/apache/storm/utils/VersionedStore.java | 4 +-
.../apache/storm/utils/WindowedTimeThrottler.java | 2 +-
.../jvm/org/apache/storm/utils/WritableUtils.java | 15 +-
.../org/apache/storm/utils/ZookeeperAuthInfo.java | 1 -
.../apache/storm/validation/ConfigValidation.java | 343 +++--
.../validation/ConfigValidationAnnotations.java | 37 +-
.../storm/validation/ConfigValidationUtils.java | 19 +-
.../jvm/org/apache/storm/validation/NotConf.java | 3 +-
.../jvm/org/apache/storm/validation/Validated.java | 2 +-
.../apache/storm/windowing/CountTriggerPolicy.java | 6 +-
.../storm/windowing/DefaultEvictionContext.java | 3 +-
.../src/jvm/org/apache/storm/windowing/Event.java | 6 +-
.../apache/storm/windowing/EvictionContext.java | 7 +-
.../org/apache/storm/windowing/EvictionPolicy.java | 27 +-
.../storm/windowing/StatefulWindowManager.java | 15 +-
.../apache/storm/windowing/TimeEvictionPolicy.java | 15 +-
.../apache/storm/windowing/TimeTriggerPolicy.java | 18 +-
.../org/apache/storm/windowing/TriggerHandler.java | 3 +-
.../org/apache/storm/windowing/TriggerPolicy.java | 8 +-
.../apache/storm/windowing/TupleWindowImpl.java | 3 +-
.../storm/windowing/WaterMarkEventGenerator.java | 24 +-
.../windowing/WatermarkCountEvictionPolicy.java | 14 +-
.../windowing/WatermarkCountTriggerPolicy.java | 9 +-
.../windowing/WatermarkTimeEvictionPolicy.java | 20 +-
.../windowing/WatermarkTimeTriggerPolicy.java | 18 +-
.../src/jvm/org/apache/storm/windowing/Window.java | 43 +-
.../storm/windowing/WindowLifecycleListener.java | 12 +-
.../org/apache/storm/windowing/WindowManager.java | 34 +-
.../persistence/SimpleWindowPartitionCache.java | 12 +-
.../persistence/WindowPartitionCache.java | 3 +-
.../storm/windowing/persistence/WindowState.java | 77 +-
.../apache/storm/zookeeper/ClientZookeeper.java | 35 +-
.../test/jvm/org/apache/storm/ConstantsTest.java | 14 +-
.../storm/PaceMakerStateStorageFactoryTest.java | 32 +-
.../jvm/org/apache/storm/TestConfigValidate.java | 271 ++--
.../jvm/org/apache/storm/TestStormSubmitter.java | 11 +-
.../test/jvm/org/apache/storm/TestStormTimer.java | 96 +-
.../assignments/LocalAssignmentsBackendTest.java | 16 +-
.../storm/blobstore/ClientBlobStoreTest.java | 9 +-
.../jvm/org/apache/storm/bolt/TestJoinBolt.java | 155 +-
.../org/apache/storm/cluster/DaemonTypeTest.java | 12 +-
.../storm/cluster/StormClusterStateImplTest.java | 6 +-
.../daemon/metrics/ClientMetricsUtilsTest.java | 6 +-
.../daemon/worker/BackPressureTrackerTest.java | 13 +-
.../storm/daemon/worker/LogConfigManagerTest.java | 69 +-
.../daemon/worker/TestUtilsForWorkerState.java | 28 +-
.../storm/daemon/worker/WorkerStateTest.java | 65 +-
.../org/apache/storm/daemon/worker/WorkerTest.java | 6 +-
.../dependency/DependencyPropertiesParserTest.java | 15 +-
.../storm/dependency/DependencyUploaderTest.java | 85 +-
.../apache/storm/executor/ChildEwmaStatsTest.java | 12 +-
.../storm/executor/EwmaFeedbackRecordTest.java | 72 +-
.../executor/ExecutorTransferControlLaneTest.java | 43 +-
.../ExecutorTransferMultiThreadingTest.java | 71 +-
.../apache/storm/executor/SpoutExecutorTest.java | 44 +-
.../storm/executor/error/ReportErrorTest.java | 21 +-
.../grouping/JitterAwareStreamGroupingTest.java | 52 +-
.../grouping/LoadAwareShuffleGroupingTest.java | 99 +-
.../apache/storm/grouping/ShuffleGroupingTest.java | 16 +-
.../BalancedTargetSelectorTest.java | 21 +-
.../partialKeyGrouping/PartialKeyGroupingTest.java | 17 +-
.../RandomTwoTaskAssignmentCreatorTest.java | 35 +-
.../DeserializingConnectionCallbackTest.java | 176 ++-
.../storm/messaging/netty/MessageDecoderTest.java | 22 +-
.../apache/storm/messaging/netty/ServerTest.java | 33 +-
.../netty/StormClientPipelineFactoryTest.java | 8 +-
.../messaging/netty/StormServerHandlerTest.java | 20 +-
.../storm/metric/FileBasedEventLoggerTest.java | 17 +-
.../metric/filter/FilterByMetricNameTest.java | 17 +-
.../storm/metric/internal/CountStatTest.java | 8 +-
.../storm/metric/internal/LatencyStatTest.java | 22 +-
.../storm/metric/internal/RateTrackerTest.java | 18 +-
.../storm/metric/util/DataPointExpanderTest.java | 27 +-
.../org/apache/storm/metrics2/EwmaGaugeTest.java | 28 +-
.../storm/metrics2/RollingAverageGaugeTest.java | 4 +-
.../org/apache/storm/metrics2/TaskMetricsTest.java | 77 +-
.../org/apache/storm/nimbus/NimbusInfoTest.java | 4 +-
.../storm/pacemaker/codec/ThriftDecoderTest.java | 64 +-
.../storm/security/auth/AuthUtilsTestMock.java | 30 +-
.../apache/storm/security/auth/AutoSSLTest.java | 17 +-
.../storm/security/auth/ClientAuthUtilsTest.java | 52 +-
.../storm/security/auth/MultiThriftServerTest.java | 20 +-
.../apache/storm/security/auth/ReqContextTest.java | 7 +-
.../security/auth/SaslTransportPluginTest.java | 6 +-
.../security/auth/ShellBasedGroupsMappingTest.java | 25 +-
.../storm/security/auth/SubjectCompatTest.java | 20 +-
.../security/auth/TestingITransportPlugin.java | 3 +-
.../storm/security/auth/ThriftClientTest.java | 20 +-
.../security/auth/TlsTransportPluginTest.java | 30 +-
.../auth/X509CertPrincipalToLocalTest.java | 21 +-
.../authorizer/DRPCSimpleACLAuthorizerTest.java | 87 +-
.../auth/authorizer/SimpleACLAuthorizerTest.java | 184 ++-
.../SupervisorSimpleACLAuthorizerTest.java | 14 +-
.../auth/kerberos/AutoLoginModuleTest.java | 35 +-
.../serialization/BlowfishTupleSerializerTest.java | 47 +-
.../GzipBridgeThriftSerializationDelegateTest.java | 5 +-
.../KryoTupleSerializerDeserializerTest.java | 127 +-
.../SerializableSerializerFilterTest.java | 149 +-
.../serialization/SerializationFactoryTest.java | 18 +-
.../ThriftBridgeSerializationDelegateTest.java | 5 +-
.../ZstdBridgeThriftSerializationDelegateTest.java | 15 +-
.../ZstdThriftSerializationDelegateTest.java | 6 +-
.../apache/storm/spout/CheckpointSpoutTest.java | 57 +-
.../storm/state/BaseBinaryStateIteratorTest.java | 22 +-
.../storm/state/DefaultStateSerializerTest.java | 48 +-
.../storm/state/InMemoryKeyValueStateTest.java | 36 +-
.../apache/storm/streams/ProcessorBoltTest.java | 39 +-
.../storm/streams/StatefulProcessorBoltTest.java | 16 +-
.../apache/storm/streams/StreamBuilderTest.java | 92 +-
.../storm/streams/WindowedProcessorBoltTest.java | 12 +-
.../processors/CoGroupByKeyProcessorTest.java | 61 +-
.../streams/processors/JoinProcessorTest.java | 24 +-
.../org/apache/storm/testing/IntegrationTest.java | 11 +-
.../org/apache/storm/testing/PerformanceTest.java | 8 +-
.../PersistentWindowedBoltExecutorTest.java | 72 +-
.../topology/SimpleWindowPartitionCacheTest.java | 123 +-
.../storm/topology/StatefulBoltExecutorTest.java | 108 +-
.../topology/StatefulWindowedBoltExecutorTest.java | 28 +-
.../apache/storm/topology/TopologyBuilderTest.java | 61 +-
.../storm/topology/WindowedBoltExecutorTest.java | 102 +-
.../apache/storm/trident/TestTridentTopology.java | 14 +-
.../apache/storm/trident/TridentWindowingTest.java | 30 +-
.../org/apache/storm/tuple/DetachedTupleTest.java | 42 +-
.../jvm/org/apache/storm/tuple/FieldsTest.java | 18 +-
.../jvm/org/apache/storm/tuple/MessageIdTest.java | 17 +-
.../org/apache/storm/utils/ConfigUtilsTest.java | 58 +-
.../org/apache/storm/utils/CuratorUtilsTest.java | 86 +-
.../storm/utils/DefaultShellLogHandlerTest.java | 10 +-
.../storm/utils/JCQueueBackpressureTest.java | 20 +-
.../jvm/org/apache/storm/utils/JCQueueTest.java | 74 +-
.../org/apache/storm/utils/PredicateMatcher.java | 4 +-
.../apache/storm/utils/ReflectionUtilsTest.java | 25 +-
.../org/apache/storm/utils/SecurityUtilsTest.java | 12 +-
.../storm/utils/ShellBoltMessageQueueTest.java | 11 +-
.../jvm/org/apache/storm/utils/ShellUtilsTest.java | 9 +-
.../org/apache/storm/utils/SimpleVersionTest.java | 4 +-
.../StormBoundedExponentialBackoffRetryTest.java | 40 +-
.../storm/utils/ThriftTopologyUtilsTest.java | 42 +-
.../test/jvm/org/apache/storm/utils/TimeTest.java | 6 +-
.../test/jvm/org/apache/storm/utils/UtilsTest.java | 218 +--
.../windowing/WaterMarkEventGeneratorTest.java | 12 +-
.../apache/storm/windowing/WindowManagerTest.java | 125 +-
.../windowing/persistence/WindowStateTest.java | 18 +-
728 files changed, 12302 insertions(+), 7784 deletions(-)
