org.apache.samza.coordinator.lifecycle

Interface JobRestartSignal

public interface JobRestartSignal

Interface for defining how to trigger a restart of a Samza job. This will be called when the Samza framework determines that a job restart is needed. For example, if the partition count of an input stream changes, then that means the job model needs to change, and restarting the job will update the job model.

Method Summary

Modifier and Type	Method and Description
void	restartJob() Trigger a restart of the Samza job.

Method Detail

restartJob

void restartJob()

Trigger a restart of the Samza job. This method should trigger the restart asynchronously, because the caller of this method is part of the Samza job which is going to be restarted. It is not necessary that the restart needs to actually happen immediately, as the job will continue to run until the restart actually happens.