org.apache.pig.backend.hadoop.executionengine

Class HExecutionEngine

java.lang.Object

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

public class HExecutionEngine
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected DataStorage	ds
static String	JOB_TRACKER_LOCATION
protected org.apache.hadoop.mapred.JobConf	jobConf
static String	LOCAL
protected Map<OperatorKey,OperatorKey>	logicalToPhysicalKeys
protected Map<OperatorKey,MapRedResult>	materializedResults
protected Map<Operator,PhysicalOperator>	newLogToPhyMap
protected PigContext	pigContext

Constructor Summary

Constructors

Constructor and Description
HExecutionEngine(PigContext pigContext)

Method Summary

Methods

Modifier and Type	Method and Description
PhysicalPlan	compile(LogicalPlan plan, Properties properties)
DataStorage	getDataStorage()
Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>>	getForEachInnerLogToPhyMap(LogicalPlan plan)
org.apache.hadoop.mapred.JobConf	getJobConf()
Map<Operator,PhysicalOperator>	getLogToPhyMap()
Map<OperatorKey,MapRedResult>	getMaterializedResults()
LogicalPlan	getNewPlan()
void	init()
void	updateConfiguration(Properties newConfiguration)

Methods inherited from class java.lang.Object

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

Field Detail

JOB_TRACKER_LOCATION

public static final String JOB_TRACKER_LOCATION

See Also:

Constant Field Values

LOCAL

public static final String LOCAL

See Also:

Constant Field Values

pigContext

protected PigContext pigContext

ds

protected DataStorage ds

jobConf

protected org.apache.hadoop.mapred.JobConf jobConf

logicalToPhysicalKeys

protected Map<OperatorKey,OperatorKey> logicalToPhysicalKeys

materializedResults

protected Map<OperatorKey,MapRedResult> materializedResults

newLogToPhyMap

protected Map<Operator,PhysicalOperator> newLogToPhyMap

Constructor Detail

HExecutionEngine

public HExecutionEngine(PigContext pigContext)

Method Detail

getJobConf

public org.apache.hadoop.mapred.JobConf getJobConf()

getMaterializedResults

public Map<OperatorKey,MapRedResult> getMaterializedResults()

getDataStorage

public DataStorage getDataStorage()

init

public void init()
          throws ExecException

Throws:

ExecException

updateConfiguration

public void updateConfiguration(Properties newConfiguration)
                         throws ExecException

Throws:

ExecException

compile

public PhysicalPlan compile(LogicalPlan plan,
                   Properties properties)
                     throws FrontendException

Throws:

FrontendException

getLogToPhyMap

public Map<Operator,PhysicalOperator> getLogToPhyMap()

getForEachInnerLogToPhyMap

public Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> getForEachInnerLogToPhyMap(LogicalPlan plan)

getNewPlan

public LogicalPlan getNewPlan()