Package org.apache.storm.trident.util
Class TridentUtils
java.lang.Object
org.apache.storm.trident.util.TridentUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic FieldsfieldsConcat(Fields... fields) static FieldsfieldsSubtract(Fields all, Fields minus) static FieldsfieldsUnion(Fields... fields) static <T> List<T>getChildren(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n) static <T> TgetParent(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n) static <T> List<T>getParents(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n) Assumes edge contains an index.static FieldsgetSingleOutputStreamFields(IComponent component) static <T> TthriftDeserialize(Class<T> c, byte[] b) static byte[]thriftSerialize(org.apache.storm.thrift.TBase t)
-
Constructor Details
-
TridentUtils
public TridentUtils()
-
-
Method Details
-
fieldsUnion
-
fieldsConcat
-
fieldsSubtract
-
getSingleOutputStreamFields
-
getParents
Assumes edge contains an index. -
getChildren
-
getParent
public static <T> T getParent(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n) -
thriftSerialize
public static byte[] thriftSerialize(org.apache.storm.thrift.TBase t) -
thriftDeserialize
-