Package | Description |
---|---|
org.apache.pig |
Public interfaces and classes for Pig.
|
org.apache.pig.backend.hadoop.executionengine.fetch | |
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | |
org.apache.pig.backend.hadoop.executionengine.physicalLayer |
Implementation of physical operators that use hadoop as the execution engine
and data storage.
|
org.apache.pig.piggybank.evaluation |
Modifier and Type | Field and Description |
---|---|
protected PigProgressable |
EvalFunc.reporter
Reporter to send heartbeats to Hadoop.
|
protected PigProgressable |
ComparisonFunc.reporter
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PigProgressable |
EvalFunc.getReporter() |
Modifier and Type | Method and Description |
---|---|
void |
EvalFunc.setReporter(PigProgressable reporter)
Set the reporter.
|
void |
ComparisonFunc.setReporter(PigProgressable reporter)
Deprecated.
Set the reporter.
|
Modifier and Type | Class and Description |
---|---|
class |
FetchProgressableReporter
A dummy ProgressableReporter used for fetch tasks
|
Modifier and Type | Class and Description |
---|---|
class |
ProgressableReporter |
Modifier and Type | Field and Description |
---|---|
protected static java.lang.ThreadLocal<PigProgressable> |
PhysicalOperator.reporter |
Modifier and Type | Method and Description |
---|---|
static PigProgressable |
PhysicalOperator.getReporter() |
Modifier and Type | Method and Description |
---|---|
static void |
PhysicalOperator.setReporter(PigProgressable reporter) |
Modifier and Type | Method and Description |
---|---|
protected static Tuple |
ExtremalTupleByNthField.extreme(int pind,
int psign,
Tuple input,
PigProgressable reporter) |
protected static Tuple |
MaxTupleBy1stField.max(Tuple input,
PigProgressable reporter) |
Copyright © 2007-2012 The Apache Software Foundation