Class TridentUtils

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

public class TridentUtils extends Object
  • Constructor Details

    • TridentUtils

      public TridentUtils()
  • Method Details

    • 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> List<T> getParents(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n)
      Assumes edge contains an index.
    • getChildren

      public static <T> List<T> getChildren(org.apache.storm.shade.org.jgrapht.DirectedGraph g, T n)
    • 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

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