Package | Description |
---|---|
org.apache.pig |
Public interfaces and classes for Pig.
|
org.apache.pig.backend.hadoop.accumulo | |
org.apache.pig.backend.hadoop.executionengine.fetch | |
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | |
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | |
org.apache.pig.backend.hadoop.hbase | |
org.apache.pig.builtin |
This package contains builtin Pig UDFs.
|
org.apache.pig.builtin.mock | |
org.apache.pig.impl.io | |
org.apache.pig.newplan.logical.relational | |
org.apache.pig.piggybank.storage |
Modifier and Type | Class and Description |
---|---|
class |
StoreFunc
StoreFuncs take records from Pig's processing and store them into a data store.
|
class |
StoreFuncMetadataWrapper
Convenience class to extend when decorating a class that implements both StoreFunc and
StoreMetadata.
|
class |
StoreFuncWrapper
Convenience class to extend when decorating a StoreFunc.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StoreFuncWrapper.setStoreFunc(StoreFuncInterface storeFunc)
The wrapped StoreFuncInterface object must be set before method calls are made on this object.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAccumuloStorage
A LoadStoreFunc for retrieving data from and storing data to Accumulo
A Key/Val pair will be returned as tuples: (key, colfam, colqual, colvis,
timestamp, value).
|
class |
AccumuloStorage
Basic PigStorage implementation that uses Accumulo as the backing store.
|
Modifier and Type | Method and Description |
---|---|
StoreFuncInterface |
FetchPOStoreImpl.createStoreFunc(POStore store) |
Modifier and Type | Method and Description |
---|---|
StoreFuncInterface |
MapReducePOStoreImpl.createStoreFunc(POStore store) |
Modifier and Type | Method and Description |
---|---|
abstract StoreFuncInterface |
POStoreImpl.createStoreFunc(POStore store)
Set up the storer
|
StoreFuncInterface |
POStore.getStoreFunc() |
StoreFuncInterface |
StoreFuncDecorator.getStorer() |
Modifier and Type | Method and Description |
---|---|
void |
POStore.setStoreFunc(StoreFuncInterface storeFunc) |
Constructor and Description |
---|
StoreFuncDecorator(StoreFuncInterface storer,
String udfSignature) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseStorage
A HBase implementation of LoadFunc and StoreFunc.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroStorage
Pig UDF for reading and writing Avro data.
|
class |
BinStorage
Load and store data in a binary format.
|
class |
JsonStorage
A JSON Pig store function.
|
class |
OrcStorage
A load function and store function for ORC file.
|
class |
ParquetStorer
Wrapper class which will delegate calls to parquet.pig.ParquetStorer
|
class |
PigStorage
A load function that parses a line of input into fields using a character delimiter.
|
class |
TrevniStorage
Pig Store/Load Function for Trevni.
|
Modifier and Type | Class and Description |
---|---|
class |
Storage
A convenient mock Storage for unit tests
|
Modifier and Type | Class and Description |
---|---|
class |
InterStorage
LOAD FUNCTION FOR PIG INTERNAL USE ONLY!
This load function is used for storing intermediate data between MR jobs of
a pig query.
|
class |
SequenceFileInterStorage
Store tuples (BinSedesTuples, specifically) using sequence files to leverage
sequence file's compression features.
|
class |
TFileStorage
LOAD FUNCTION FOR PIG INTERNAL USE ONLY! This load function is used for
storing intermediate data between MR jobs of a pig query.
|
Modifier and Type | Method and Description |
---|---|
StoreFuncInterface |
LOStore.getStoreFunc() |
Constructor and Description |
---|
LOStore(LogicalPlan plan,
FileSpec outputFileSpec,
StoreFuncInterface storeFunc,
String signature) |
LOStore(LogicalPlan plan,
FileSpec outputFileSpec,
StoreFuncInterface storeFunc,
String signature,
boolean disambiguationEnabled) |
Modifier and Type | Class and Description |
---|---|
class |
CSVExcelStorage
CSV loading and storing with support for multi-line fields,
and escaping of delimiters and double quotes within fields;
uses CSV conventions of Excel 2007.
|
class |
DBStorage |
class |
FixedWidthStorer
Stores Pig records in a fixed-width file format.
|
class |
HiveColumnarStorage |
class |
IndexedStorage
IndexedStorage is a form of PigStorage that supports a
per record seek. |
class |
MultiStorage
The UDF is useful for splitting the output data into a bunch of directories
and files dynamically based on user specified key field in the output tuple.
|
class |
PigStorageSchema
Deprecated.
Use PigStorage with a -schema option instead
|
Copyright © 2007-2017 The Apache Software Foundation