Package org.apache.storm.trident.util
Class TridentUtils
java.lang.Object
org.apache.storm.trident.util.TridentUtils
- 
Constructor SummaryConstructors
- 
Method SummaryModifier 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- 
TridentUtilspublic TridentUtils()
 
- 
- 
Method Details- 
fieldsUnion
- 
fieldsConcat
- 
fieldsSubtract
- 
getSingleOutputStreamFields
- 
getParentsAssumes edge contains an index.
- 
getChildren
- 
getParentpublic static <T> T getParent(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n) 
- 
thriftSerializepublic static byte[] thriftSerialize(org.apache.storm.thrift.TBase t) 
- 
thriftDeserialize
 
-