org.apache.storm.utils

Class TestUtils

java.lang.Object

org.apache.storm.utils.Utils

org.apache.storm.utils.TestUtils

public class TestUtils
extends Utils

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.storm.utils.Utils

Utils.SmartThread, Utils.UptimeComputer

Field Summary

Fields inherited from class org.apache.storm.utils.Utils

CLASS_PATH_SEPARATOR, CURRENT_BLOB_SUFFIX_ID, DEFAULT_BLOB_VERSION_SUFFIX, DEFAULT_CURRENT_BLOB_SUFFIX, DEFAULT_STREAM_ID, FILE_PATH_SEPARATOR, IS_ON_WINDOWS, LOG, SIGKILL, SIGTERM

Constructor Summary

Constructors

Constructor and Description
TestUtils()

Method Summary

Modifier and Type	Method and Description
static void	testSetupBuilder(org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map conf, ZookeeperAuthInfo auth)

Methods inherited from class org.apache.storm.utils.Utils

addShutdownHookWithForceKillIn1Sec, addToClasspath, addToClasspath, addToClasspathImpl, addToClasspathImpl, addVersions, asyncLoop, asyncLoop, asyncLoop, bitXor, bitXorVals, canUserReadBlob, CheckDirExists, checkFileExists, checkFileExists, checkFileExists, constructBlobCurrentSymlinkName, constructBlobWithVersionFileName, constructVersionFileName, containerFilePath, convertClojureMapToJavaMap, createLocalizer, currentClasspath, currentClasspathImpl, deserialize, downloadResourcesAsSupervisor, downloadResourcesAsSupervisorImpl, eventLogsFilename, exceptionCauseIsInstanceOf, execCommand, exitProcess, extractDirFromJar, extractDirFromJarImpl, findAndReadConfigFile, findAndReadConfigFile, findResources, forceDelete, forceDeleteImpl, forceKillProcess, fromCompressedJsonConf, get, getAvailablePort, getAvailablePort, getBoolean, getClientBlobStore, getClientBlobStoreForSupervisor, getComponentCommon, getConfiguredClass, getDouble, getDouble, getDU, getFileOwner, getGlobalStreamId, getInt, getInt, getNimbusBlobStore, getNimbusBlobStore, getRepeat, getSetComponentObject, getString, getString, getStrings, getSuperUserAcl, getTopologyId, getTopologyInfo, getWorkerACL, gunzip, gzip, handleUncaughtException, hostname, hostnameImpl, integerDivided, interleaveAll, isAbsolutePath, isOnWindows, isSystemId, isValidConf, isValidKey, isZkAuthenticationConfiguredStormServer, isZkAuthenticationConfiguredTopology, jarTransformer, javaDeserialize, javaSerialize, join, joinMaps, killProcessWithSigTerm, loadClojureFn, localHostname, localHostnameImpl, localVersionOfBlob, logsFilename, makeUptimeComputer, makeUptimeComputerImpl, memoizedLocalHostname, mkSuicideFn, newCurator, newCurator, newCurator, newCuratorStarted, newCuratorStarted, newInstance, newInstance, newInstanceImpl, nimbusVersionOfBlob, nullToZero, OR, parseJvmHeapMemByChildOpts, parseZkId, partitionFixed, processPid, readAndLogStream, readCommandLineOpts, readDefaultConfig, readDirContents, readStormConfig, readYamlFile, redactValue, resetClassLoaderForJavaDeSerialize, restrictPermissions, reverseMap, reverseMap, scriptFilePath, secureRandomLong, sendSignalToProcess, serialize, setClassLoaderForJavaDeSerialize, setInstance, setupBuilder, setupDefaultUncaughtExceptionHandler, shellCmd, sleep, threadDump, thriftDeserialize, thriftDeserialize, thriftSerialize, toByteArray, toCompressedJsonConf, toPositive, tuple, unJar, unpack, unTar, unZip, uuid, validateKeyName, validateTopologyBlobStoreMap, wrapInRuntime, writeScript, zeroIfNaNOrInf, zipDoesContainDir, zipFileSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestUtils

public TestUtils()

Method Detail

testSetupBuilder

public static void testSetupBuilder(org.apache.curator.framework.CuratorFrameworkFactory.Builder builder,
                                    String zkStr,
                                    Map conf,
                                    ZookeeperAuthInfo auth)