org.apache.pig.backend.hadoop.executionengine.physicalLayer

Interface PigProgressable

All Known Implementing Classes:

FetchProgressableReporter, ProgressableReporter

@InterfaceAudience.Public
 @InterfaceStability.Stable
public interface PigProgressable

Pig's progress indicator. An implemenation of this interface is passed to UDFs to allow them to send heartbeats. By default Hadoop will kill a task if it does not receive a heartbeat every 600 seconds. Any operation that may take more than this should call progress on a regular basis.

Method Summary

Modifier and Type	Method and Description
void	progress() Report progress.
void	progress(String msg) Report progress with a message.

Method Detail

progress

void progress()

Report progress.

progress

void progress(String msg)

Report progress with a message.

Parameters:

msg - message to send with progress report.