Github user roshannaik commented on a diff in the pull request:
https://github.com/apache/storm/pull/2502#discussion_r161357014
--- Diff: storm-client/src/jvm/org/apache/storm/StormTimer.java ---
@@ -193,6 +210,24 @@ public void run() {
});
}
+ /**
+ * Schedule a function to run recurrently
+ * @param delayMs the number of millis to delay before running the
function
+ * @param recurMs the time between each invocation
+ * @param func the function to run
+ */
+ public void scheduleRecurringMs(long delayMs, final long recurMs,
final Runnable func) {
+ scheduleMs(delayMs, new Runnable() {
--- End diff --
Doesn't seem feasible due to the 'this' reference inside the lambda.
---
