org.apache.samza.task

Interface TimerCallback<K>

Type Parameters:

K - type of the timer key

public interface TimerCallback<K>

The callback that is invoked when its corresponding timer registered via TaskContext fires.

Method Summary

Modifier and Type	Method and Description
void	onTimer(K key, MessageCollector collector, TaskCoordinator coordinator) Invoked when the timer of key fires.

Method Detail

onTimer

void onTimer(K key,
             MessageCollector collector,
             TaskCoordinator coordinator)

Invoked when the timer of key fires.

Parameters:

key - timer key

collector - contains the means of sending message envelopes to the output stream.

coordinator - manages execution of tasks.