org.apache.samza.task

Interface DrainListenerTask

public interface DrainListenerTask

The DrainListenerTask augments StreamTask allowing the method implementor to specify code to be executed when the 'drain' is reached for a task.

Method Summary

Modifier and Type	Method and Description
void	onDrain(MessageCollector collector, TaskCoordinator coordinator) Guaranteed to be invoked when all SSPs processed by this task have drained.

Method Detail

onDrain

void onDrain(MessageCollector collector,
             TaskCoordinator coordinator)
      throws java.lang.Exception

Guaranteed to be invoked when all SSPs processed by this task have drained.

Parameters:

collector - Contains the means of sending message envelopes to an output stream.*

coordinator - Manages execution of tasks.

Throws:

java.lang.Exception - Any exception types encountered during the execution of the processing task.