Package | Description |
---|---|
org.apache.pig |
Public interfaces and classes for Pig.
|
org.apache.pig.builtin |
This package contains builtin Pig UDFs.
|
org.apache.pig.piggybank.evaluation | |
org.apache.pig.scripting.groovy | |
org.apache.pig.scripting.jruby |
Modifier and Type | Interface and Description |
---|---|
interface |
TerminatingAccumulator<T>
This is an interface which, if implemented, allows an Accumulator
function to signal that it can terminate early.
|
Modifier and Type | Class and Description |
---|---|
class |
AccumulatorEvalFunc<T>
This class is used to provide a free implementation of the EvalFunc exec function given
implementation of the Accumulator interface.
|
class |
AlgebraicEvalFunc<T>
This class is used to provide a free implementation of the Accumulator interface
and EvalFunc class in the case of an Algebraic function.
|
class |
IteratingAccumulatorEvalFunc<T>
This class provides a much more intuitive way to write Accumulator UDFs.
For example, you could express IsEmpty as follows: |
Modifier and Type | Class and Description |
---|---|
class |
AlgebraicBigDecimalMathBase
Core logic for applying an SUM function to a
bag of BigDecimals.
|
class |
AlgebraicBigIntegerMathBase
Core logic for applying an SUM function to a
bag of BigIntegers.
|
class |
AlgebraicByteArrayMathBase
Core logic for applying an accumulative/algebraic math function to a
bag of doubles.
|
class |
AlgebraicDoubleMathBase
Core logic for applying an accumulative/algebraic math function to a
bag of doubles.
|
class |
AlgebraicFloatMathBase
Core logic for applying an accumulative/algebraic math function to a
bag of Floats.
|
class |
AlgebraicIntMathBase
Core logic for applying an accumulative/algebraic math function to a
bag of doubles.
|
class |
AlgebraicLongMathBase
Core logic for applying an accumulative/algebraic math function to a
bag of Longs.
|
class |
AVG
Generates the average of a set of values.
|
class |
BigDecimalAvg
This method should never be used directly, use
AVG . |
class |
BigDecimalMax
This method should never be used directly, use
MAX . |
class |
BigDecimalMin
This method should never be used directly, use
MIN . |
class |
BigDecimalSum
This method should never be used directly, use
SUM . |
class |
BigIntegerAvg
This method should never be used directly, use
AVG . |
class |
BigIntegerMax
This method should never be used directly, use
MAX . |
class |
BigIntegerMin
This method should never be used directly, use
MIN . |
class |
BigIntegerSum
This method should never be used directly, use
SUM . |
class |
COUNT
Generates the count of the number of values in a bag.
|
class |
COUNT_STAR
Generates the count of the values of the first field of a tuple.
|
class |
DateTimeMax
This method should never be used directly, use
MAX . |
class |
DateTimeMin
This method should never be used directly, use
MAX . |
class |
DoubleAvg
This method should never be used directly, use
AVG . |
class |
DoubleMax
This method should never be used directly, use
MAX . |
class |
DoubleMin
This method should never be used directly, use
MIN . |
class |
DoubleSum
This method should never be used directly, use
SUM . |
class |
FloatAvg
This method should never be used directly, use
AVG . |
class |
FloatMax
This method should never be used directly, use
MAX . |
class |
FloatMin
This method should never be used directly, use
MIN . |
class |
FloatSum
This method should never be used directly, use
SUM . |
class |
IntAvg
This method should never be used directly, use
AVG . |
class |
IntMax
This method should never be used directly, use
MAX . |
class |
IntMin
This method should never be used directly, use
MIN . |
class |
IntSum
This method should never be used directly, use
SUM . |
class |
LongAvg
This method should never be used directly, use
AVG . |
class |
LongMax
This method should never be used directly, use
MAX . |
class |
LongMin
This method should never be used directly, use
MIN . |
class |
LongSum
This method should never be used directly, use
SUM . |
class |
MAX
Generates the maximum of a set of values.
|
class |
MIN
Generates the minimum of a set of values.
|
class |
StringMax
This method should never be used directly, use
MAX . |
class |
StringMin
This method should never be used directly, use
MIN . |
class |
SUM
Generates the sum of a set of values.
|
class |
TOP
Top UDF accepts a bag of tuples and returns top-n tuples depending upon the
tuple field value of type long.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtremalTupleByNthField
This class is similar to MaxTupleBy1stField except that it allows you to
specify with field to use (instead of just using 1st field) and to specify
ascending or descending.
|
class |
MaxTupleBy1stField
MaxTupleBy1stField UDF returns a tuple with max value of the first field in a
given bag.
|
Modifier and Type | Class and Description |
---|---|
class |
JrubyAccumulatorEvalFunc
This class provides a bridge between Ruby classes that extend AccumulatorPigUdf
and their execution in Pig.
|
class |
JrubyAlgebraicEvalFunc<T>
This class provides the bridge between Ruby classes that extend the AlgebraicPigUdf
"interface" by implementing an initial, intermed, and final method.
|
static class |
JrubyAlgebraicEvalFunc.BagJrubyAlgebraicEvalFunc
Unlike EvalFuncs and Accumulators, the type must be known at compile time (ie it
can't return Object), as Pig inspects the type and ensures that it is valid.
|
static class |
JrubyAlgebraicEvalFunc.ChararrayJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.DataByteArrayJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.DoubleJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.FloatJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.IntegerJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.LongJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.MapJrubyAlgebraicEvalFunc |
static class |
JrubyAlgebraicEvalFunc.TupleJrubyAlgebraicEvalFunc |
Copyright © 2007-2017 The Apache Software Foundation