Class MRScriptState

  extended by
      extended by

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
ScriptState.AliasVisitor, ScriptState.FeatureVisitor, ScriptState.PIG_FEATURE, ScriptState.PIG_PROPERTY
Field Summary
Fields inherited from class
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
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


public MRScriptState(String id)
Method Detail


public static MRScriptState get()


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


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


public String getAlias(MapReduceOper mro)


public String getAliasLocation(MapReduceOper mro)


public String getPigFeature(MapReduceOper mro)

Copyright © 2007-2012 The Apache Software Foundation