org.apache.samza.scheduler

Interface CallbackScheduler

public interface CallbackScheduler

Provides a way for applications to register some logic to be executed at a future time.

Method Summary

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.

Method Detail

scheduleCallback

<K> void scheduleCallback(K key,
                          long timestamp,
                          ScheduledCallback<K> callback)

Schedule the 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.

Type Parameters:

K - type of the key

Parameters:

key - callback key

timestamp - epoch time when the callback will be fired, in milliseconds

callback - callback to run

deleteCallback

<K> void deleteCallback(K key)

Delete the scheduled callback for the key. Deletion only happens if the callback hasn't been fired. Otherwise it will not interrupt.

Type Parameters:

K - type of the key

Parameters:

key - callback key