org.apache.samza.operators

Interface TimerRegistry<K>

Type Parameters:

K - type of the timer key

public interface TimerRegistry<K>

Allows registering epoch-time timer callbacks from the operators. See TimerFunction for details.

Method Summary

Modifier and Type	Method and Description
void	delete(K key) Delete the timer for the provided key.
void	register(K key, long timestamp) Register a epoch-time timer with key.

Method Detail

register

void register(K key,
              long timestamp)

Register a epoch-time timer with key.

Parameters:

key - unique timer key

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

delete

void delete(K key)

Delete the timer for the provided key.

Parameters:

key - key for the timer to delete