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 Summary
Constructors Constructor Description OnlyLatestExecutor(Executor exec)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
execute(K key, Runnable r)
Run something in the future, but replace it with the latest if it is taking too long.
-
-
-
Constructor Detail
-
OnlyLatestExecutor
public OnlyLatestExecutor(Executor exec)
-
-