@InterfaceAudience.Public @InterfaceStability.Evolving public interface ExecutionEngine
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Perform any cleanup operation
|
void |
explain(LogicalPlan lp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose,
File dir,
String suffix)
This method handles the backend processing of the Explain command.
|
Properties |
getConfiguration()
Returns the Properties representation of the ExecutionEngine
configuration.
|
DataStorage |
getDataStorage()
Returns the DataStorage the ExecutionEngine is using.
|
ExecutableManager |
getExecutableManager()
Returns the ExecutableManager to be used in Pig Streaming.
|
void |
init()
This method is responsible for the initialization of the ExecutionEngine.
|
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.
|
void |
kill()
This method is called when user requests to kill all jobs
associated with the execution engine
|
void |
killJob(String jobID)
This method is called when a user requests to kill a job associated with
the given job id.
|
PigStats |
launchPig(LogicalPlan lp,
String grpName,
PigContext pc)
This method is responsible for the actual execution of a LogicalPlan.
|
void |
setConfiguration(Properties newConfiguration)
Responsible for updating the properties for the ExecutionEngine.
|
void |
setProperty(String property,
String value)
Responsible for setting a specific property and value.
|
void init() throws ExecException
ExecException
void setConfiguration(Properties newConfiguration) throws ExecException
newConfiguration
- -- Properties object holding all configuration valsExecException
void setProperty(String property, String value)
property
- to updatevalue
- to set for propertyProperties getConfiguration()
PigStats launchPig(LogicalPlan lp, String grpName, PigContext pc) throws FrontendException, ExecException
lp
- -- plan to compilegrpName
- -- group name for submissionpc
- -- context for executionExecException
FrontendException
void explain(LogicalPlan lp, PigContext pc, PrintStream ps, String format, boolean verbose, File dir, String suffix) throws PlanException, VisitorException, IOException
lp
- -- plan to explainpc
- -- context for explain processingps
- -- print stream to write all output to (if dir param is null)format
- -- format to print explainverbose
- dir
- -- directory to write output to. if not null, write to filessuffix
- -- if writing to files, suffix to be used for each filePlanException
VisitorException
IOException
DataStorage getDataStorage()
ScriptState instantiateScriptState()
PigStats instantiatePigStats()
ExecutableManager getExecutableManager()
void kill() throws BackendException
BackendException
void killJob(String jobID) throws BackendException
BackendException
void destroy()
Copyright © 2007-2017 The Apache Software Foundation