org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Class MRExecutionEngine

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.HExecutionEngine

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRExecutionEngine

All Implemented Interfaces:

ExecutionEngine

public class MRExecutionEngine
extends HExecutionEngine

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine

ALTERNATIVE_FILE_SYSTEM_LOCATION, CORE_DEFAULT_SITE, CORE_SITE, ds, FILE_SYSTEM_LOCATION, HADOOP_SITE, JOB_TRACKER_LOCATION, launcher, LOCAL, logicalToPhysicalKeys, MAPRED_DEFAULT_SITE, MAPREDUCE_FRAMEWORK_NAME, newLogToPhyMap, pigContext, YARN_DEFAULT_SITE, YARN_SITE

Constructor Summary

Constructors

Constructor and Description
MRExecutionEngine(PigContext pigContext)

Method Summary

Modifier and Type	Method and Description
PigStats	instantiatePigStats() Creates a PigStats object which will be accessible as a ThreadLocal variable inside the PigStats class.
ScriptState	instantiateScriptState() Creates a ScriptState object which will be accessible as a ThreadLocal variable inside the ScriptState class.

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine

compile, explain, getConfiguration, getDataStorage, getExecConf, getExecutableManager, getForEachInnerLogToPhyMap, getJobConf, getLocalConf, getLogToPhyMap, init, killJob, launchPig, setConfiguration, setProperty

Methods inherited from class java.lang.Object

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

Constructor Detail

MRExecutionEngine

public MRExecutionEngine(PigContext pigContext)

Method Detail

instantiateScriptState

public ScriptState instantiateScriptState()

Description copied from interface: ExecutionEngine

Creates a ScriptState object which will be accessible as a ThreadLocal variable inside the ScriptState class. This method is called when first initializing the ScriptState as to delegate to the ExecutionEngine the version of ScriptState to use to manage the execution at hand.

Returns:

ScriptState object to manage execution of the script

instantiatePigStats

public PigStats instantiatePigStats()

Description copied from interface: ExecutionEngine

Creates a PigStats object which will be accessible as a ThreadLocal variable inside the PigStats class. This method is called when first initializing the PigStats.

Returns:

PigStats object.