Package org.apache.storm.utils
package org.apache.storm.utils
-
ClassDescriptionDefault implementation of
ShellLogHandler.UserGroupInformation#loginUserFromKeytab(String, String) changes the static fields of UserGroupInformation, especially the current logged-in user, and UserGroupInformation itself is not thread-safe.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.Implementation of VersionInfo that uses a properties file to get the VersionInfo.A simple, durable, atomic K/V database.LruMap<A,B> Client used for connecting to nimbus.An interface to allow callbacks with a thrift nimbus client.This exception class is used to signify a problem with nimbus leader identification.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.A data structure for ShellBolt which includes two queues (FIFO), which one is for task ids (unbounded), another one is for bolt msg (bounded).Contains convenience functions for running shell commands for cases that are too simple to need a fullShellUtilsimplementation.Handle logging from non-JVM processes.This is an IOException with exit code added.OSType detection.A simple shell command executor.Take a version string and parse out a Major.Minor versionClient for interacting with Supervisor server, now we use supervisor server mainly for cases below.This class implements time simulation support.TimeCacheMap<K,V> Deprecated.A thread that can answer if it is sleeping in the case of simulated time.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.Wraps the generated TException to allow getMessage() to return a valid string.