Class and Description |
---|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadMetadata
This interface defines how to retrieve metadata related to data to be loaded.
|
LoadPushDown
This interface defines how to communicate to Pig what functionality can
be pushed into the loader.
|
Class and Description |
---|
Accumulator
An interface that allows UDFs that take a bag to accumulate tuples in chunks rather than take
the whole set at once.
|
AccumulatorEvalFunc
This class is used to provide a free implementation of the EvalFunc exec function given
implementation of the Accumulator interface.
|
Algebraic
An interface to declare that an EvalFunc's
calculation can be decomposed into intitial, intermediate, and final steps.
|
ErrorHandler
The interface that handles errors thrown by the
StoreFuncInterface.putNext(Tuple) |
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
EvalFunc.SchemaType
EvalFunc's schema type.
|
ExceptionalFunction
An interface that captures a unit of work against an item where an exception might be thrown.
|
ExecType
The type of query execution.
|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
Expression.OpType |
FileSplitComparable
This class represents a relative position in a file.
|
FuncSpec
Class to represent a UDF specification.
|
JVMReuseManager
This class is used to manage JVM Reuse in case of execution engines like Tez
and Spark.
|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadFuncWrapper
Convenience class to extend when decorating a LoadFunc.
|
LoadMetadata
This interface defines how to retrieve metadata related to data to be loaded.
|
LoadPushDown.OperatorSet
Set of possible operations that Pig can push down to a loader.
|
LoadPushDown.RequiredField
Describes a field that is required to execute a scripts.
|
LoadPushDown.RequiredFieldList
List of fields that Pig knows to be required to executed a script.
|
LoadPushDown.RequiredFieldResponse
Indicates whether the loader will return the requested fields or all fields.
|
OrderedLoadFunc
Implementing this interface indicates to Pig that a given loader
can be used for MergeJoin.
|
PigCounters
The following enum will contain the general counters that pig uses.
|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
PigServer.Graph |
PigToStream
Deprecated.
Use
PigStreamingBase |
PigWarning
An enum to enumerate the warning types in Pig
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceSchema.Order |
ResourceSchema.ResourceFieldSchema |
ResourceStatistics
An class that represents statistics about data to be loaded or stored.
|
ResourceStatistics.ResourceFieldStatistics
Statistics for a given field in the data.
|
SortColInfo
A class representing information about a sort column in
SortInfo |
SortColInfo.Order |
SortInfo
Class to communicate sort column information based on
order by statment's sort columns and schema
|
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.
|
StoreFuncWrapper
Convenience class to extend when decorating a StoreFunc.
|
StoreMetadata
This interface defines how to write metadata related to data to be stored.
|
StreamToPig
Deprecated.
Use
PigStreamingBase |
TerminatingAccumulator
This is an interface which, if implemented, allows an Accumulator
function to signal that it can terminate early.
|
TypedOutputEvalFunc
Base class for Pig UDFs that are functions from Tuples to generic type OUT.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadStoreCaster
This is just a union interface of LoadCaster and StoreCaster,
made available for simplicity.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceSchema.ResourceFieldSchema |
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.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
StoreFuncInterface
StoreFuncs take records from Pig's processing and store them into a data store.
|
Class and Description |
---|
ExecType
The type of query execution.
|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
StoreFuncInterface
StoreFuncs take records from Pig's processing and store them into a data store.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
ComparisonFunc
Deprecated.
|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
ResourceSchema.ResourceFieldSchema |
Class and Description |
---|
FuncSpec
Class to represent a UDF specification.
|
LoadFunc
A LoadFunc loads data into Pig.
|
SortInfo
Class to communicate sort column information based on
order by statment's sort columns and schema
|
StoreFuncInterface
StoreFuncs take records from Pig's processing and store them into a data store.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
ExecType
The type of query execution.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
LoadFunc
A LoadFunc loads data into Pig.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
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. |
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadPushDown
This interface defines how to communicate to Pig what functionality can
be pushed into the loader.
|
LoadPushDown.OperatorSet
Set of possible operations that Pig can push down to a loader.
|
LoadPushDown.RequiredFieldList
List of fields that Pig knows to be required to executed a script.
|
LoadPushDown.RequiredFieldResponse
Indicates whether the loader will return the requested fields or all fields.
|
LoadStoreCaster
This is just a union interface of LoadCaster and StoreCaster,
made available for simplicity.
|
OrderedLoadFunc
Implementing this interface indicates to Pig that a given loader
can be used for MergeJoin.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceSchema.ResourceFieldSchema |
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.
|
StoreResources
This interface allow StoreFunc to specify resources needed
in distributed cache.
|
Class and Description |
---|
Accumulator
An interface that allows UDFs that take a bag to accumulate tuples in chunks rather than take
the whole set at once.
|
AccumulatorEvalFunc
This class is used to provide a free implementation of the EvalFunc exec function given
implementation of the Accumulator interface.
|
Algebraic
An interface to declare that an EvalFunc's
calculation can be decomposed into intitial, intermediate, and final steps.
|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
EvalFunc.SchemaType
EvalFunc's schema type.
|
ExceptionalFunction
An interface that captures a unit of work against an item where an exception might be thrown.
|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
Expression.OpType |
FileInputLoadFunc
This class provides an implementation of OrderedLoadFunc interface
which can be optionally re-used by LoadFuncs that use FileInputFormat, by
having this as a super class
|
FilterFunc |
FuncSpec
Class to represent a UDF specification.
|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadFuncMetadataWrapper
Convenience class to extend when decorating a class that extends LoadFunc and
implements LoadMetadata.
|
LoadFuncWrapper
Convenience class to extend when decorating a LoadFunc.
|
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.
|
LoadPushDown.OperatorSet
Set of possible operations that Pig can push down to a loader.
|
LoadPushDown.RequiredFieldList
List of fields that Pig knows to be required to executed a script.
|
LoadPushDown.RequiredFieldResponse
Indicates whether the loader will return the requested fields or all fields.
|
LoadStoreCaster
This is just a union interface of LoadCaster and StoreCaster,
made available for simplicity.
|
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. |
PigStreamingBase
The interface is used for the custom mapping of
- a
Tuple to a byte array. |
PigToStream
Deprecated.
Use
PigStreamingBase |
PrimitiveEvalFunc
Base class for simple Pig UDFs that are functions of primitive types IN to OUT.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceSchema.ResourceFieldSchema |
ResourceStatistics
An class that represents statistics about data to be loaded or stored.
|
StaticDataCleanup |
StoreCaster
An interface that provides methods for converting Pig internal types to byte[].
|
StoreFunc
StoreFuncs take records from Pig's processing and store them into a data store.
|
StoreFuncInterface
StoreFuncs take records from Pig's processing and store them into a data store.
|
StoreFuncMetadataWrapper
Convenience class to extend when decorating a class that implements both StoreFunc and
StoreMetadata.
|
StoreFuncWrapper
Convenience class to extend when decorating a StoreFunc.
|
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
PigStreamingBase |
TypedOutputEvalFunc
Base class for Pig UDFs that are functions from Tuples to generic type OUT.
|
Class and Description |
---|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadMetadata
This interface defines how to retrieve metadata related to data to be loaded.
|
PigServer
A class for Java programs to connect to Pig.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceStatistics
An class that represents statistics about data to be loaded or stored.
|
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.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
ResourceSchema.ResourceFieldSchema |
Class and Description |
---|
ExecType
The type of query execution.
|
FuncSpec
Class to represent a UDF specification.
|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
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.
|
LoadFunc
A LoadFunc loads data into Pig.
|
Class and Description |
---|
ExecType
The type of query execution.
|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
FileInputLoadFunc
This class provides an implementation of OrderedLoadFunc interface
which can be optionally re-used by LoadFuncs that use FileInputFormat, by
having this as a super class
|
FuncSpec
Class to represent a UDF specification.
|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadMetadata
This interface defines how to retrieve metadata related to data to be loaded.
|
OrderedLoadFunc
Implementing this interface indicates to Pig that a given loader
can be used for MergeJoin.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceStatistics
An class that represents statistics about data to be loaded or stored.
|
StoreFuncInterface
StoreFuncs take records from Pig's processing and store them into a data store.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
LoadCaster
An interface that provides cast implementations for load functions.
|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
PigStreamingBase
The interface is used for the custom mapping of
- a
Tuple to a byte array. |
PigToStream
Deprecated.
Use
PigStreamingBase |
StreamToPig
Deprecated.
Use
PigStreamingBase |
Class and Description |
---|
FileInputLoadFunc
This class provides an implementation of OrderedLoadFunc interface
which can be optionally re-used by LoadFuncs that use FileInputFormat, by
having this as a super class
|
FuncSpec
Class to represent a UDF specification.
|
LoadCaster
An interface that provides cast implementations for load functions.
|
LoadFunc
A LoadFunc loads data into Pig.
|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
PigWarning
An enum to enumerate the warning types in Pig
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceSchema.ResourceFieldSchema |
Class and Description |
---|
LoadPushDown.RequiredField
Describes a field that is required to execute a scripts.
|
LoadPushDown.RequiredFieldList
List of fields that Pig knows to be required to executed a script.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
Class and Description |
---|
ResourceSchema.ResourceFieldSchema |
Class and Description |
---|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
Expression.OpType |
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
FuncSpec
Class to represent a UDF specification.
|
LoadFunc
A LoadFunc loads data into Pig.
|
SortInfo
Class to communicate sort column information based on
order by statment's sort columns and schema
|
StoreFuncInterface
StoreFuncs take records from Pig's processing and store them into a data store.
|
Class and Description |
---|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
Class and Description |
---|
EvalFunc.SchemaType
EvalFunc's schema type.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
PigServer
A class for Java programs to connect to Pig.
|
Class and Description |
---|
PigException
All exceptions in Pig are encapsulated in the
PigException
class. |
Class and Description |
---|
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.
|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
Algebraic
An interface to declare that an EvalFunc's
calculation can be decomposed into intitial, intermediate, and final steps.
|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
Expression
A class to communicate Filter expressions to LoadFuncs.
|
FileInputLoadFunc
This class provides an implementation of OrderedLoadFunc interface
which can be optionally re-used by LoadFuncs that use FileInputFormat, by
having this as a super class
|
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.
|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadMetadata
This interface defines how to retrieve metadata related to data to be loaded.
|
LoadPushDown
This interface defines how to communicate to Pig what functionality can
be pushed into the loader.
|
LoadPushDown.OperatorSet
Set of possible operations that Pig can push down to a loader.
|
LoadPushDown.RequiredFieldList
List of fields that Pig knows to be required to executed a script.
|
LoadPushDown.RequiredFieldResponse
Indicates whether the loader will return the requested fields or all fields.
|
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. |
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceStatistics
An class that represents statistics about data to be loaded or stored.
|
StoreFunc
StoreFuncs take records from Pig's processing and store them into a data store.
|
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.
|
Class and Description |
---|
FuncSpec
Class to represent a UDF specification.
|
Class and Description |
---|
LoadFunc
A LoadFunc loads data into Pig.
|
LoadMetadata
This interface defines how to retrieve metadata related to data to be loaded.
|
LoadPushDown
This interface defines how to communicate to Pig what functionality can
be pushed into the loader.
|
Class and Description |
---|
FileInputLoadFunc
This class provides an implementation of OrderedLoadFunc interface
which can be optionally re-used by LoadFuncs that use FileInputFormat, by
having this as a super class
|
OrderedLoadFunc
Implementing this interface indicates to Pig that a given loader
can be used for MergeJoin.
|
ResourceSchema
A represenation of a schema used to communicate with load and store functions.
|
ResourceSchema.ResourceFieldSchema |
Class and Description |
---|
LoadFunc
A LoadFunc loads data into Pig.
|
Class and Description |
---|
ExecType
The type of query execution.
|
Class and Description |
---|
Accumulator
An interface that allows UDFs that take a bag to accumulate tuples in chunks rather than take
the whole set at once.
|
AccumulatorEvalFunc
This class is used to provide a free implementation of the EvalFunc exec function given
implementation of the Accumulator interface.
|
Algebraic
An interface to declare that an EvalFunc's
calculation can be decomposed into intitial, intermediate, and final steps.
|
AlgebraicEvalFunc
This class is used to provide a free implementation of the Accumulator interface
and EvalFunc class in the case of an Algebraic function.
|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
Accumulator
An interface that allows UDFs that take a bag to accumulate tuples in chunks rather than take
the whole set at once.
|
AccumulatorEvalFunc
This class is used to provide a free implementation of the EvalFunc exec function given
implementation of the Accumulator interface.
|
Algebraic
An interface to declare that an EvalFunc's
calculation can be decomposed into intitial, intermediate, and final steps.
|
AlgebraicEvalFunc
This class is used to provide a free implementation of the Accumulator interface
and EvalFunc class in the case of an Algebraic function.
|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
EvalFunc
The class is used to implement functions to be applied to
fields in a dataset.
|
Class and Description |
---|
ExecType
The type of query execution.
|
PigServer
A class for Java programs to connect to Pig.
|
Class and Description |
---|
PigServer
A class for Java programs to connect to Pig.
|
Class and Description |
---|
PigServer
A class for Java programs to connect to Pig.
|
Copyright © 2007-2012 The Apache Software Foundation