org.apache.pig.scripting

Class ScriptingOutputCapturer

java.lang.Object

org.apache.pig.scripting.ScriptingOutputCapturer

public class ScriptingOutputCapturer
extends java.lang.Object

This class helps a scripting UDF capture user output by managing when to capture output and where the output is written to. For illustrate, we will only capture output for the last run (with the final set of data) and we need to keep track of the file containing that output for returning w/ the illustrate results. For runs, all standard output is written to the user logs.

Constructor Summary

Constructors

Constructor and Description
ScriptingOutputCapturer(ExecType execType)

Method Summary

Modifier and Type	Method and Description
static java.lang.String	getRunId()
java.lang.String	getStandardOutputRootWriteLocation()
java.lang.String	getTaskLogDir(java.lang.String jobId, java.lang.String taskId, java.lang.String hadoopLogDir)
static java.util.Map<java.lang.String,java.lang.String>	getUdfOutput()
static boolean	isClassCapturingOutput()
boolean	isInstanceCapturingOutput()
void	registerOutputLocation(java.lang.String functionName, java.lang.String fileName)
void	setInstanceCapturingOutput(boolean instanceCapturingOutput)
static void	startCapturingOutput()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScriptingOutputCapturer

public ScriptingOutputCapturer(ExecType execType)

Method Detail

getStandardOutputRootWriteLocation

public java.lang.String getStandardOutputRootWriteLocation()
                                                    throws java.io.IOException

Throws:

java.io.IOException

getTaskLogDir

public java.lang.String getTaskLogDir(java.lang.String jobId,
                                      java.lang.String taskId,
                                      java.lang.String hadoopLogDir)
                               throws java.io.IOException

Throws:

java.io.IOException

startCapturingOutput

public static void startCapturingOutput()

getUdfOutput

public static java.util.Map<java.lang.String,java.lang.String> getUdfOutput()
                                                                     throws java.io.IOException

Throws:

java.io.IOException

registerOutputLocation

public void registerOutputLocation(java.lang.String functionName,
                                   java.lang.String fileName)

getRunId

public static java.lang.String getRunId()

isClassCapturingOutput

public static boolean isClassCapturingOutput()

isInstanceCapturingOutput

public boolean isInstanceCapturingOutput()

setInstanceCapturingOutput

public void setInstanceCapturingOutput(boolean instanceCapturingOutput)