Package | Description |
---|---|
org.apache.pig.backend.datastorage | |
org.apache.pig.backend.executionengine | |
org.apache.pig.backend.hadoop.executionengine | |
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | |
org.apache.pig.backend.hadoop.executionengine.spark | |
org.apache.pig.backend.hadoop.executionengine.tez | |
org.apache.pig.data |
This package contains implementations of Pig specific data types as well as
support functions for reading, writing, and using all Pig data types.
|
org.apache.pig.impl.streaming | |
org.apache.pig.piggybank.storage |
Modifier and Type | Class and Description |
---|---|
class |
DataStorageException |
Modifier and Type | Class and Description |
---|---|
class |
ExecException |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionEngine.kill()
This method is called when user requests to kill all jobs
associated with the execution engine
|
void |
ExecutionEngine.killJob(String jobID)
This method is called when a user requests to kill a job associated with
the given job id.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
Launcher.kill() |
void |
HExecutionEngine.kill() |
void |
HExecutionEngine.killJob(String jobID) |
abstract void |
Launcher.killJob(String jobID,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
MapReduceLauncher.killJob(String jobID,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
SparkLauncher.kill() |
void |
SparkLauncher.killJob(String jobID,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
TezLauncher.kill() |
void |
TezLauncher.killJob(String jobID,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Class and Description |
---|---|
class |
FieldIsNullException |
Modifier and Type | Class and Description |
---|---|
class |
StreamingUDFException |
Modifier and Type | Method and Description |
---|---|
protected void |
SequenceFileLoader.setKeyType(Class<?> keyClass) |
protected void |
SequenceFileLoader.setValueType(Class<?> valueClass) |
Copyright © 2007-2017 The Apache Software Foundation