public class ExecutionRuntime
extends java.lang.Object
Constructor and Description |
---|
ExecutionRuntime(java.lang.String jName,
ExecutionPlan execPlan,
TWSChannel ch) |
Modifier and Type | Method and Description |
---|---|
<T,O extends InputSplit<T>> |
createInput(Config cfg,
TaskContext context,
InputPartitioner<T,O> input) |
TWSChannel |
getChannel() |
java.lang.String |
getJobName() |
Path |
getParentpath() |
ExecutionPlan |
getPlan() |
void |
setJobName(Config config) |
void |
setJobName(java.lang.String jobName) |
void |
setParentpath(Path parentpath) |
public ExecutionRuntime(java.lang.String jName, ExecutionPlan execPlan, TWSChannel ch)
public java.lang.String getJobName()
public void setJobName(java.lang.String jobName)
public void setJobName(Config config)
public TWSChannel getChannel()
public ExecutionPlan getPlan()
public Path getParentpath()
public void setParentpath(Path parentpath)
public <T,O extends InputSplit<T>> DataSource<T,O> createInput(Config cfg, TaskContext context, InputPartitioner<T,O> input)