| 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.
|
| 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) |
Copyright © 2007-2025 The Apache Software Foundation