Class OnlyLatestExecutor<K>

java.lang.Object
org.apache.storm.daemon.supervisor.OnlyLatestExecutor<K>

public class OnlyLatestExecutor<K> extends Object
This allows you to submit a Runnable with a key. If the previous submission for that key has not yet run, it will be replaced with the latest one.
  • Constructor Details

    • OnlyLatestExecutor

      public OnlyLatestExecutor(Executor exec)
  • Method Details

    • execute

      public void execute(K key, Runnable r)
      Run something in the future, but replace it with the latest if it is taking too long.
      Parameters:
      key - what to use to dedupe things.
      r - what you want to run.