org.apache.samza.scheduler

Interface ScheduledCallback<K>

Type Parameters:

K - type of the callback key

public interface ScheduledCallback<K>

The callback that is invoked when its corresponding schedule time registered via CallbackScheduler is reached. The CallbackScheduler is available through TaskContext.getCallbackScheduler().

Method Summary

Modifier and Type	Method and Description
void	onCallback(K key, MessageCollector collector, TaskCoordinator coordinator) Invoked when the corresponding schedule time is reached.

Method Detail

onCallback

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

Invoked when the corresponding schedule time is reached.

Parameters:

key - key for callback

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

coordinator - manages execution of tasks.