Class TupleUtils

java.lang.Object
org.apache.storm.utils.TupleUtils

public final class TupleUtils extends Object
  • Method Details

    • isTick

      public static boolean isTick(Tuple tuple)
    • chooseTaskIndex

      public static <T> int chooseTaskIndex(List<T> keys, int numTasks)
    • putTickFrequencyIntoComponentConfig

      public static Map<String,Object> putTickFrequencyIntoComponentConfig(Map<String,Object> conf, int tickFreqSecs)