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 SummaryConstructors
- 
Method Summary
- 
Constructor Details- 
OnlyLatestExecutor
 
- 
- 
Method Details- 
executeRun 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.
 
 
-