Modifier and Type | Method and Description |
---|---|
protected PigStats |
PigServer.launchPlan(LogicalPlan lp,
java.lang.String jobName)
A common method for launching the jobs according to the logical plan
|
static PigStats |
PigRunner.run(java.lang.String[] args,
PigProgressNotificationListener listener) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<ExecJob> |
PigServer.getJobs(PigStats stats)
Retrieves a list of Job objects from the PigStats object
|
Modifier and Type | Method and Description |
---|---|
PigStats |
ExecJob.getStatistics()
Can be information about the state (not submitted, e.g.
|
PigStats |
ExecutionEngine.instantiatePigStats()
Creates a PigStats object which will be accessible as a ThreadLocal
variable inside the PigStats class.
|
PigStats |
ExecutionEngine.launchPig(LogicalPlan lp,
java.lang.String grpName,
PigContext pc)
This method is responsible for the actual execution of a LogicalPlan.
|
Modifier and Type | Method and Description |
---|---|
PigStats |
HJob.getStatistics() |
PigStats |
HExecutionEngine.launchPig(LogicalPlan lp,
java.lang.String grpName,
PigContext pc) |
abstract PigStats |
Launcher.launchPig(PhysicalPlan php,
java.lang.String grpName,
PigContext pc)
Method to launch pig for hadoop either for a cluster's job tracker or for
a local job runner.
|
Constructor and Description |
---|
HJob(ExecJob.JOB_STATUS status,
PigContext pigContext,
POStore store,
java.lang.String alias,
PigStats stats) |
Modifier and Type | Method and Description |
---|---|
PigStats |
FetchLauncher.launchPig(PhysicalPlan pp)
Runs the fetch task by executing chain of calls on the PhysicalPlan from the leaf
up to the LoadFunc
|
Modifier and Type | Method and Description |
---|---|
PigStats |
MRExecutionEngine.instantiatePigStats() |
PigStats |
MapReduceLauncher.launchPig(PhysicalPlan php,
java.lang.String grpName,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
PigStats |
SparkExecutionEngine.instantiatePigStats() |
PigStats |
SparkLauncher.launchPig(PhysicalPlan physicalPlan,
java.lang.String grpName,
PigContext pigContext) |
Modifier and Type | Method and Description |
---|---|
PigStats |
TezExecutionEngine.instantiatePigStats() |
PigStats |
TezLauncher.launchPig(PhysicalPlan php,
java.lang.String grpName,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
PigStats |
BoundScript.runSingle()
Run a pipeline on Hadoop.
|
PigStats |
BoundScript.runSingle(java.util.Properties prop)
Run a pipeline on Hadoop.
|
PigStats |
BoundScript.runSingle(java.lang.String propfile)
Run a pipeline on Hadoop.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.List<PigStats>> |
ScriptEngine.getPigStatsMap()
Gets the collection of
PigStats after the script is run. |
protected abstract java.util.Map<java.lang.String,java.util.List<PigStats>> |
ScriptEngine.main(PigContext context,
java.lang.String scriptFile)
Actually runs the script file.
|
java.util.List<PigStats> |
BoundScript.run()
Run multiple instances of bound pipeline on Hadoop in parallel.
|
java.util.Map<java.lang.String,java.util.List<PigStats>> |
ScriptEngine.run(PigContext pigContext,
java.lang.String scriptFile)
Runs a script file.
|
java.util.List<PigStats> |
BoundScript.run(java.util.Properties prop)
Run multiple instances of bound pipeline on Hadoop in parallel.
|
java.util.List<PigStats> |
BoundScript.run(java.lang.String propfile)
Run multiple instances of bound pipeline on Hadoop in parallel.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.List<PigStats>> |
GroovyScriptEngine.main(PigContext context,
java.lang.String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.List<PigStats>> |
JrubyScriptEngine.main(PigContext pigContext,
java.lang.String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.List<PigStats>> |
JsScriptEngine.main(PigContext pigContext,
java.lang.String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.List<PigStats>> |
JythonScriptEngine.main(PigContext pigContext,
java.lang.String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.util.List<PigStats>> |
PythonScriptEngine.main(PigContext context,
java.lang.String scriptFile) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyPigStats
EmptyPigStats encapsulates dummy statistics of a fetch task, since during a
fetch no MR jobs are executed
|
Modifier and Type | Method and Description |
---|---|
static PigStats |
PigStats.get() |
static PigStats |
PigStatsUtil.getEmptyPigStats()
Deprecated.
|
static PigStats |
PigStatsUtil.getPigStats(int code)
Returns the PigStats with the given return code
|
static PigStats |
PigStats.start(PigStats stats) |
Modifier and Type | Method and Description |
---|---|
abstract java.util.Map<java.lang.String,java.util.List<PigStats>> |
PigStats.getAllStats() |
java.util.Map<java.lang.String,java.util.List<PigStats>> |
EmptyPigStats.getAllStats() |
Modifier and Type | Method and Description |
---|---|
static PigStats |
PigStats.start(PigStats stats) |
Modifier and Type | Method and Description |
---|---|
static void |
PigStatsUtil.setStatsMap(java.util.Map<java.lang.String,java.util.List<PigStats>> statsMap) |
Modifier and Type | Class and Description |
---|---|
class |
SimplePigStats
SimplePigStats encapsulates the statistics collected from a running script.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<PigStats>> |
SimplePigStats.getAllStats() |
Modifier and Type | Method and Description |
---|---|
static MRJobStats |
MRPigStatsUtil.addNativeJobStats(PigStats ps,
NativeMapReduceOper mr,
boolean success) |
static MRJobStats |
MRPigStatsUtil.addNativeJobStats(PigStats ps,
NativeMapReduceOper mr,
boolean success,
java.lang.Exception e) |
Modifier and Type | Class and Description |
---|---|
class |
SparkPigStats |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<PigStats>> |
SparkPigStats.getAllStats() |
Modifier and Type | Method and Description |
---|---|
static void |
SparkStatsUtil.addFailedNativeJobStats(PigStats ps,
NativeSparkOperator nativeSparkOperator,
java.lang.Exception e) |
static void |
SparkStatsUtil.addNativeJobStats(PigStats ps,
NativeSparkOperator nativeSparkOperator) |
Modifier and Type | Class and Description |
---|---|
class |
TezPigScriptStats |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.List<PigStats>> |
TezPigScriptStats.getAllStats() |
Copyright © 2007-2017 The Apache Software Foundation