Package org.apache.storm.trident.util
Class TridentUtils
java.lang.Object
org.apache.storm.trident.util.TridentUtils
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic Fields
fieldsConcat
(Fields... fields) static Fields
fieldsSubtract
(Fields all, Fields minus) static Fields
fieldsUnion
(Fields... fields) static <T> List<T>
getChildren
(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n) static <T> T
getParent
(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 Fields
getSingleOutputStreamFields
(IComponent component) static <T> T
thriftDeserialize
(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
-