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
 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.


Copyright © 2007-2012 The Apache Software Foundation