org.apache.pig.tools.pigstats.mapreduce

Class MRScriptState

java.lang.Object

org.apache.pig.tools.pigstats.ScriptState

org.apache.pig.tools.pigstats.mapreduce.MRScriptState

public class MRScriptState
extends ScriptState

ScriptStates encapsulates settings for a Pig script that runs on a hadoop cluster. These settings are added to all MR jobs spawned by the script and in turn are persisted in the hadoop job xml. With the properties already in the job xml, users who want to know the relations between the script and MR jobs can derive them from the job xmls.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.tools.pigstats.ScriptState

ScriptState.AliasVisitor, ScriptState.FeatureVisitor, ScriptState.PIG_FEATURE, ScriptState.PIG_PROPERTY

Field Summary

Fields inherited from class org.apache.pig.tools.pigstats.ScriptState

commandLine, fileName, hadoopVersion, id, listeners, pigContext, pigVersion, scriptFeatures, serializedScript, truncatedScript

Constructor Summary

Constructors

Constructor and Description
MRScriptState(String id)

Method Summary

Modifier and Type	Method and Description
void	addSettingsToConf(MapReduceOper mro, org.apache.hadoop.conf.Configuration conf)
void	addWorkflowAdjacenciesToConf(MROperPlan mrop, org.apache.hadoop.conf.Configuration conf)
static MRScriptState	get()
String	getAlias(MapReduceOper mro)
String	getAliasLocation(MapReduceOper mro)
String	getPigFeature(MapReduceOper mro)

Methods inherited from class org.apache.pig.tools.pigstats.ScriptState

bitSetToLong, emitInitialPlanNotification, emitJobFailedNotification, emitjobFinishedNotification, emitJobsSubmittedNotification, emitJobStartedNotification, emitLaunchCompletedNotification, emitLaunchStartedNotification, emitOutputCompletedNotification, emitProgressUpdatedNotification, featureLongToString, getAllListeners, getCommandLine, getFileName, getHadoopVersion, getId, getPigContext, getPigVersion, getScript, getScriptFeatures, getSerializedScript, registerListener, setCommandLine, setFileName, setPigContext, setScript, setScript, setScript, setScriptFeatures, start, start

Methods inherited from class java.lang.Object

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

Constructor Detail

MRScriptState

public MRScriptState(String id)

Method Detail

get

public static MRScriptState get()

addSettingsToConf

public void addSettingsToConf(MapReduceOper mro,
                              org.apache.hadoop.conf.Configuration conf)

addWorkflowAdjacenciesToConf

public void addWorkflowAdjacenciesToConf(MROperPlan mrop,
                                         org.apache.hadoop.conf.Configuration conf)

getAlias

public String getAlias(MapReduceOper mro)

getAliasLocation

public String getAliasLocation(MapReduceOper mro)

getPigFeature

public String getPigFeature(MapReduceOper mro)