# Package org.apache.storm.utils

package org.apache.storm.utils

- Related Packages
  Package
  Description
  org.apache.storm
- Class
  Description
  BatchHelper
  BufferFileInputStream
  BufferInputStream
  ConfigUtils
  CRC32OutputStream
  CuratorUtils
  DaemonConfigValidation
  DaemonConfigValidation.NumaEntryValidator
  DefaultShellLogHandler
  Default implementation of `ShellLogHandler`.
  DisallowedStrategyException
  DRPCClient
  DRPCClient.LocalOverride
  EnumUtil
  EquivalenceUtils
  ExtendedThreadPoolExecutor
  HadoopLoginUtil
  UserGroupInformation#loginUserFromKeytab(String, String) changes the static fields of UserGroupInformation, especially the current logged-in user, and UserGroupInformation itself is not thread-safe.
  InprocMessaging
  IPredicate<T>
  This interface is implemented by classes, instances of which can be passed into certain Util functions which test some collection for elements matching the IPredicate.
  IVersionInfo
  Implementation of VersionInfo that uses a properties file to get the VersionInfo.
  JCQueue
  JCQueue.Consumer
  JCQueue.ExitCondition
  JCQueueMetrics
  KeyedRoundRobinQueue<V>
  ListDelegate
  LocalState
  A simple, durable, atomic K/V database.
  LruMap<A,B>
  LruMap.CacheEvictionCallback<K,V>
  Monitor
  MutableInt
  MutableLong
  MutableObject
  NimbusClient
  Client used for connecting to nimbus.
  NimbusClient.Builder
  NimbusClient.LocalOverride
  NimbusClient.WithNimbus
  An interface to allow callbacks with a thrift nimbus client.
  NimbusLeaderNotFoundException
  This exception class is used to signify a problem with nimbus leader identification.
  ObjectReader
  ReflectionUtils
  RegisteredGlobalState
  This class is used as part of testing Storm.
  RotatingMap<K,V>
  Expires keys that have not been updated in the configured number of seconds.
  RotatingMap.ExpiredCallback<K,V>
  SecurityUtils
  ServerConfigUtils
  ServerUtils
  ServiceRegistry
  ShellBoltMessageQueue
  A data structure for ShellBolt which includes two queues (FIFO), which one is for task ids (unbounded), another one is for bolt msg (bounded).
  ShellCommandRunner
  Contains convenience functions for running shell commands for cases that are too simple to need a full `ShellUtils` implementation.
  ShellCommandRunnerImpl
  ShellLogHandler
  Handle logging from non-JVM processes.
  ShellProcess
  ShellUtils
  ShellUtils.ExitCodeException
  This is an IOException with exit code added.
  ShellUtils.OSType
  OSType detection.
  ShellUtils.ShellCommandExecutor
  A simple shell command executor.
  SimpleVersion
  Take a version string and parse out a Major.Minor version
  StormBoundedExponentialBackoffRetry
  StormCommonInstaller
  SupervisorClient
  Client for interacting with Supervisor server, now we use supervisor server mainly for cases below.
  SupervisorClient.Builder
  SupervisorIfaceFactory
  ThriftTopologyUtils
  Time
  This class implements time simulation support.
  Time.SimulatedTime
  TimeCacheMap<K,V>
  Deprecated.
  TimeCacheMap.ExpiredCallback<K,V>
  TopologySpoutLag
  TransferDrainer
  TupleUtils
  Utils
  Utils.SmartThread
  A thread that can answer if it is sleeping in the case of simulated time.
  Utils.UptimeComputer
  VersionedStore
  VersionInfo
  WebAppUtils
  WindowedTimeThrottler
  WrappedAlreadyAliveException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedAuthorizationException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedDRPCExecutionException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedHBExecutionException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedIllegalStateException
  WrappedInvalidTopologyException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedKeyAlreadyExistsException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedKeyNotFoundException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WrappedNotAliveException
  Wraps the generated TException to allow getMessage() to return a valid string.
  WritableUtils
  ZookeeperAuthInfo
  ZookeeperServerCnxnFactory