public class Utils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_STREAM_ID |
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static java.lang.Object |
deserialize(byte[] serialized) |
static int |
getFreePort()
Get available port.
|
static java.lang.Integer |
getInt(java.lang.Object o) |
static java.lang.Long |
getLong(java.lang.Object o) |
static boolean |
isValidConf(Config heronConf) |
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) |
public static final java.lang.String DEFAULT_STREAM_ID
public static java.util.List<java.lang.Object> tuple(java.lang.Object... values)
public static void sleep(long millis)
public static boolean isValidConf(Config heronConf)
public static java.util.Map<java.lang.String,java.lang.String> readCommandLineOpts()
public static byte[] serialize(java.lang.Object obj)
public static java.lang.Object deserialize(byte[] serialized)
public static java.lang.Integer getInt(java.lang.Object o)
public static java.lang.Long getLong(java.lang.Object o)
public static byte[] toByteArray(java.nio.ByteBuffer buffer)
public static int getFreePort()