backtype.storm.utils

Class Utils

java.lang.Object

backtype.storm.utils.Utils

public final class Utils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_STREAM_ID

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	deserialize(byte[] serialized)
static <S,T> T	get(java.util.Map<S,T> m, S key, T defaultValue)
static boolean	getBoolean(java.lang.Object o, boolean defaultValue)
static java.lang.Integer	getInt(java.lang.Object o)
static java.lang.Object	newInstance(java.lang.String klass)
static java.util.Map<java.lang.String,java.lang.String>	readCommandLineOpts()
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

Method Detail

newInstance

public static java.lang.Object newInstance(java.lang.String klass)

tuple

public static java.util.List<java.lang.Object> tuple(java.lang.Object... values)

sleep

public static void sleep(long millis)

readCommandLineOpts

public static java.util.Map<java.lang.String,java.lang.String> readCommandLineOpts()

serialize

public static byte[] serialize(java.lang.Object obj)

deserialize

public static java.lang.Object deserialize(byte[] serialized)

getInt

public static java.lang.Integer getInt(java.lang.Object o)

getBoolean

public static boolean getBoolean(java.lang.Object o,
                                 boolean defaultValue)

toByteArray

public static byte[] toByteArray(java.nio.ByteBuffer buffer)

get

public static <S,T> T get(java.util.Map<S,T> m,
                          S key,
                          T defaultValue)