backtype.storm.utils
Class Utils
java.lang.Object
backtype.storm.utils.Utils
public class Utils
- extends java.lang.Object
Constructor Summary |
Utils()
|
Method Summary |
static java.lang.Object |
deserialize(byte[] serialized)
|
static void |
downloadFromMaster(java.util.Map conf,
java.lang.String file,
java.lang.String localFile)
|
static java.util.Map |
findAndReadConfigFile(java.lang.String name)
|
static java.util.Map |
findAndReadConfigFile(java.lang.String name,
boolean mustExist)
|
static java.util.List<java.net.URL> |
findResources(java.lang.String name)
|
static
|
get(java.util.Map<S,T> m,
S key,
T def)
|
static ComponentCommon |
getComponentCommon(StormTopology topology,
java.lang.String id)
|
static java.lang.Integer |
getInt(java.lang.Object o)
|
static java.lang.Object |
getSetComponentObject(ComponentObject obj)
|
static java.util.TreeMap<java.lang.Integer,java.lang.Integer> |
integerDivided(int sum,
int numPieces)
(defn integer-divided [sum num-pieces]
(let [base (int (/ sum num-pieces))
num-inc (mod sum num-pieces)
num-bases (- num-pieces num-inc)]
(if (= num-inc 0)
{base num-bases}
{base num-bases (inc base) num-inc}
))) |
static boolean |
isSystemId(java.lang.String id)
|
static boolean |
isValidConf(java.util.Map<java.lang.String,java.lang.Object> stormConf)
|
static
|
join(java.lang.Iterable<T> coll,
java.lang.String sep)
|
static IFn |
loadClojureFn(java.lang.String namespace,
java.lang.String name)
|
static CuratorFramework |
newCurator(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port)
|
static CuratorFramework |
newCurator(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port,
java.lang.String root)
|
static CuratorFramework |
newCurator(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port,
java.lang.String root,
ZookeeperAuthInfo auth)
|
static CuratorFramework |
newCuratorStarted(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port)
|
static CuratorFramework |
newCuratorStarted(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port,
java.lang.String root)
|
static java.util.Map |
readCommandLineOpts()
|
static java.util.Map |
readDefaultConfig()
|
static java.util.Map |
readStormConfig()
|
static
|
reverseMap(java.util.Map<K,V> map)
|
static long |
secureRandomLong()
|
static byte[] |
serialize(java.lang.Object obj)
|
static void |
sleep(long millis)
|
static byte[] |
toByteArray(java.nio.ByteBuffer buffer)
|
static java.util.List<java.lang.Object> |
tuple(java.lang.Object... values)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_STREAM_ID
public static final java.lang.String DEFAULT_STREAM_ID
- See Also:
- Constant Field Values
Utils
public Utils()
serialize
public static byte[] serialize(java.lang.Object obj)
deserialize
public static java.lang.Object deserialize(byte[] serialized)
join
public static <T> java.lang.String join(java.lang.Iterable<T> coll,
java.lang.String sep)
sleep
public static void sleep(long millis)
findResources
public static java.util.List<java.net.URL> findResources(java.lang.String name)
findAndReadConfigFile
public static java.util.Map findAndReadConfigFile(java.lang.String name,
boolean mustExist)
findAndReadConfigFile
public static java.util.Map findAndReadConfigFile(java.lang.String name)
readDefaultConfig
public static java.util.Map readDefaultConfig()
readCommandLineOpts
public static java.util.Map readCommandLineOpts()
readStormConfig
public static java.util.Map readStormConfig()
isValidConf
public static boolean isValidConf(java.util.Map<java.lang.String,java.lang.Object> stormConf)
getSetComponentObject
public static java.lang.Object getSetComponentObject(ComponentObject obj)
get
public static <S,T> T get(java.util.Map<S,T> m,
S key,
T def)
tuple
public static java.util.List<java.lang.Object> tuple(java.lang.Object... values)
downloadFromMaster
public static void downloadFromMaster(java.util.Map conf,
java.lang.String file,
java.lang.String localFile)
throws java.io.IOException,
TException
- Throws:
java.io.IOException
TException
loadClojureFn
public static IFn loadClojureFn(java.lang.String namespace,
java.lang.String name)
isSystemId
public static boolean isSystemId(java.lang.String id)
reverseMap
public static <K,V> java.util.Map<V,K> reverseMap(java.util.Map<K,V> map)
getComponentCommon
public static ComponentCommon getComponentCommon(StormTopology topology,
java.lang.String id)
getInt
public static java.lang.Integer getInt(java.lang.Object o)
secureRandomLong
public static long secureRandomLong()
newCurator
public static CuratorFramework newCurator(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port,
java.lang.String root)
newCurator
public static CuratorFramework newCurator(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port,
java.lang.String root,
ZookeeperAuthInfo auth)
newCurator
public static CuratorFramework newCurator(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port)
newCuratorStarted
public static CuratorFramework newCuratorStarted(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port,
java.lang.String root)
newCuratorStarted
public static CuratorFramework newCuratorStarted(java.util.Map conf,
java.util.List<java.lang.String> servers,
java.lang.Object port)
integerDivided
public static java.util.TreeMap<java.lang.Integer,java.lang.Integer> integerDivided(int sum,
int numPieces)
- (defn integer-divided [sum num-pieces]
(let [base (int (/ sum num-pieces))
num-inc (mod sum num-pieces)
num-bases (- num-pieces num-inc)]
(if (= num-inc 0)
{base num-bases}
{base num-bases (inc base) num-inc}
)))
- Parameters:
sum
- numPieces
-
- Returns:
toByteArray
public static byte[] toByteArray(java.nio.ByteBuffer buffer)