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

java.lang.Object
  extended by org.apache.pig.tools.pigstats.ScriptState
      extended by 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, script, scriptFeatures
 
Constructor Summary
MRScriptState(String id)
           
 
Method Summary
 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, 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)


Copyright © 2007-2012 The Apache Software Foundation