backtype.storm.utils
Class Utils

java.lang.Object
  backtype.storm.utils.Utils

public class Utils
extends java.lang.Object

Field Summary

static java.lang.String

DEFAULT_STREAM_ID

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 <S,T> T	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 <T> java.lang.String	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	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 long	randomLong()
static java.util.Map	readDefaultConfig()
static java.util.Map	readStormConfig()
static <K,V> java.util.Map<V,K>	reverseMap(java.util.Map<K,V> map)
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

Field Detail

DEFAULT_STREAM_ID

public static final java.lang.String DEFAULT_STREAM_ID

See Also:

Constant Field Values

Constructor Detail

Utils

public Utils()

Method Detail

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)

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()

readStormConfig

public static java.util.Map readStormConfig()

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)

randomLong

public static long randomLong()

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)

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)