Class StreamUtil

java.lang.Object
org.apache.storm.streams.StreamUtil

public class StreamUtil extends Object
  • Constructor Details

    • StreamUtil

      public StreamUtil()
  • Method Details

    • getParents

      public static <T> List<T> getParents(org.apache.storm.shade.org.jgrapht.DirectedGraph<org.apache.storm.streams.Node,org.apache.storm.streams.Edge> graph, org.apache.storm.streams.Node node)
    • getChildren

      public static <T> List<T> getChildren(org.apache.storm.shade.org.jgrapht.DirectedGraph<org.apache.storm.streams.Node,org.apache.storm.streams.Edge> graph, org.apache.storm.streams.Node node)
    • isPunctuation

      public static boolean isPunctuation(Object value)
    • getPunctuationStream

      public static String getPunctuationStream(String stream)
    • getSourceStream

      public static String getSourceStream(String stream)
    • getPunctuationFields

      public static Fields getPunctuationFields()