storm.trident.util
Class TridentUtils

java.lang.Object
  storm.trident.util.TridentUtils

public class TridentUtils
extends java.lang.Object

Constructor Summary

TridentUtils()

Method Summary

static Fields	fieldsConcat(Fields... fields)
static Fields	fieldsSubtract(Fields all, Fields minus)
static Fields	fieldsUnion(Fields... fields)
static <T> java.util.List<T>	getChildren(DirectedGraph g, T n)
static <T> T	getParent(DirectedGraph g, T n)
static <T> java.util.List<T>	getParents(DirectedGraph g, T n) Assumes edge contains an index
static Fields	getSingleOutputStreamFields(IComponent component)
static <T> T	thriftDeserialize(java.lang.Class c, byte[] b)
static byte[]	thriftSerialize(TBase t)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentUtils

public TridentUtils()

Method Detail

fieldsUnion

public static Fields fieldsUnion(Fields... fields)

fieldsConcat

public static Fields fieldsConcat(Fields... fields)

fieldsSubtract

public static Fields fieldsSubtract(Fields all,
                                    Fields minus)

getSingleOutputStreamFields

public static Fields getSingleOutputStreamFields(IComponent component)

getParents

public static <T> java.util.List<T> getParents(DirectedGraph g,
                                               T n)

Assumes edge contains an index

getChildren

public static <T> java.util.List<T> getChildren(DirectedGraph g,
                                                T n)

getParent

public static <T> T getParent(DirectedGraph g,
                              T n)

thriftSerialize

public static byte[] thriftSerialize(TBase t)

thriftDeserialize

public static <T> T thriftDeserialize(java.lang.Class c,
                                      byte[] b)