Class OnlyLatestExecutor<K>
java.lang.Object
org.apache.storm.daemon.supervisor.OnlyLatestExecutor<K>
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
-
Method Summary
-
Constructor Details
-
OnlyLatestExecutor
-
-
Method Details
-
execute
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.
-