org.apache.samza.operators

Interface Scheduler<K>

Type Parameters:

K - type of the key to schedule

public interface Scheduler<K>

Allows scheduling ScheduledFunction callbacks to be invoked later.

Method Summary

Modifier and Type	Method and Description
void	delete(K key) Delete the scheduled callback for the provided key.
void	schedule(K key, long timestamp) Schedule a callback for the key to be invoked at timestamp.

Method Detail

schedule

void schedule(K key,
              long timestamp)

Schedule a callback for the key to be invoked at timestamp.

Parameters:

key - unique key associated with the callback to schedule

timestamp - epoch time when the callback for the key will be invoked, in milliseconds

delete

void delete(K key)

Delete the scheduled callback for the provided key.

Parameters:

key - key to delete