Modifier and Type | Method and Description |
---|---|
protected PigStats |
PigServer.launchPlan(LogicalPlan lp,
String jobName)
A common method for launching the jobs according to the logical plan
|
static PigStats |
PigRunner.run(String[] args,
PigProgressNotificationListener listener) |
Modifier and Type | Method and Description |
---|---|
protected 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,
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,
String grpName,
PigContext pc) |
abstract PigStats |
Launcher.launchPig(PhysicalPlan php,
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,
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,
String grpName,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
PigStats |
TezExecutionEngine.instantiatePigStats() |
PigStats |
TezLauncher.launchPig(PhysicalPlan php,
String grpName,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
PigStats |
BoundScript.runSingle()
Run a pipeline on Hadoop.
|
PigStats |
BoundScript.runSingle(Properties prop)
Run a pipeline on Hadoop.
|
PigStats |
BoundScript.runSingle(String propfile)
Run a pipeline on Hadoop.
|
Modifier and Type | Method and Description |
---|---|
protected Map<String,List<PigStats>> |
ScriptEngine.getPigStatsMap()
Gets the collection of
PigStats after the script is run. |
protected abstract Map<String,List<PigStats>> |
ScriptEngine.main(PigContext context,
String scriptFile)
Actually runs the script file.
|
List<PigStats> |
BoundScript.run()
Run multiple instances of bound pipeline on Hadoop in parallel.
|
Map<String,List<PigStats>> |
ScriptEngine.run(PigContext pigContext,
String scriptFile)
Runs a script file.
|
List<PigStats> |
BoundScript.run(Properties prop)
Run multiple instances of bound pipeline on Hadoop in parallel.
|
List<PigStats> |
BoundScript.run(String propfile)
Run multiple instances of bound pipeline on Hadoop in parallel.
|
Modifier and Type | Method and Description |
---|---|
protected Map<String,List<PigStats>> |
GroovyScriptEngine.main(PigContext context,
String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,List<PigStats>> |
JrubyScriptEngine.main(PigContext pigContext,
String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,List<PigStats>> |
JsScriptEngine.main(PigContext pigContext,
String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,List<PigStats>> |
JythonScriptEngine.main(PigContext pigContext,
String scriptFile) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,List<PigStats>> |
PythonScriptEngine.main(PigContext context,
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 Map<String,List<PigStats>> |
PigStats.getAllStats() |
Map<String,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(Map<String,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 |
---|---|
Map<String,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,
Exception e) |
Modifier and Type | Class and Description |
---|---|
class |
TezPigScriptStats |
Modifier and Type | Method and Description |
---|---|
Map<String,List<PigStats>> |
TezPigScriptStats.getAllStats() |
Copyright © 2007-2012 The Apache Software Foundation