Changed Classes and Interfaces |
Accumulator
|
An interface that allows UDFs that take a bag to accumulate tuples in chunks rather than take the whole set at once. |
Algebraic
|
An interface to declare that an EvalFunc's calculation can be decomposed into intitial intermediate and final steps. |
CollectableLoadFunc
|
This interface implemented by a LoadFunc implementations indicates to Pig that it has the capability to load data such that all instances of a key will occur in same split. |
ErrorHandler
|
The interface that handles errors thrown by the StoreFuncInterface#putNext(Tuple) |
ErrorHandling
|
A StoreFunc should implement this interface to enable handling errors during {@code StoreFunc#putNext(Tuple)} |
EvalFunc
|
The class is used to implement functions to be applied to fields in a dataset. |
ExceptionalFunction
|
An interface that captures a unit of work against an item where an exception might be thrown. |
ExecType
|
The type of query execution. |
Function
|
A convenience typedef that ties into both google's {@code Function} and {@code ExceptionalFunction}. |
IndexableLoadFunc
|
This class is intended for use by LoadFunc implementations which have an internal index for sorted data and can use the index to support merge join in Pig. |
LoadCaster
|
An interface that provides cast implementations for load functions. |
LoadMetadata
|
This interface defines how to retrieve metadata related to data to be loaded. |
LoadPredicatePushdown
|
This interface defines how a loader can support predicate pushdown. |
LoadPushDown
|
This interface defines how to communicate to Pig what functionality can be pushed into the loader. |
OrderedLoadFunc
|
Implementing this interface indicates to Pig that a given loader can be used for MergeJoin. |
OverwritableStoreFunc
|
A StoreFunc should implement this interface to enable overwriting its store/output location if it already exists. |
PigConfiguration
|
Container for static configuration strings defaults etc. |
PigServer
|
A class for Java programs to connect to Pig. |
PigToStream
|
@deprecated Use org.apache.pig.PigStreamingBase |
PigWarning
|
An enum to enumerate the warning types in Pig |
StoreCaster
|
An interface that provides methods for converting Pig internal types to byte[]. |
StoreFuncInterface
|
StoreFuncs take records from Pig's processing and store them into a data store. |
StoreMetadata
|
This interface defines how to write metadata related to data to be stored. |
StoreResources
|
This interface allow StoreFunc to specify resources needed in distributed cache. |
StreamToPig
|
@deprecated Use org.apache.pig.PigStreamingBase |
TerminatingAccumulator
|
This is an interface which if implemented allows an Accumulator function to signal that it can terminate early. |