public interface CallbackScheduler
Modifier and Type | Method and Description |
---|---|
<K> void |
deleteCallback(K key)
Delete the scheduled
callback for the key . |
<K> void |
scheduleCallback(K key,
long timestamp,
ScheduledCallback<K> callback)
Schedule the
callback for the provided key to be invoked at epoch-time timestamp . |
<K> void scheduleCallback(K key, long timestamp, ScheduledCallback<K> callback)
callback
for the provided key
to be invoked at epoch-time timestamp
.
The callback will be invoked exclusively with any other operations for this task, e.g. processing, windowing, and
commit.K
- type of the keykey
- callback keytimestamp
- epoch time when the callback will be fired, in millisecondscallback
- callback to run<K> void deleteCallback(K key)
callback
for the key
.
Deletion only happens if the callback hasn't been fired. Otherwise it will not interrupt.K
- type of the keykey
- callback key