|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of EvalFunc in org.apache.pig |
---|
Subclasses of EvalFunc in org.apache.pig | |
---|---|
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 |
FilterFunc
|
class |
IteratingAccumulatorEvalFunc<T>
This class provides a much more intuitive way to write Accumulator UDFs. For example, you could express IsEmpty as follows: |
class |
PrimitiveEvalFunc<IN,OUT>
Base class for simple Pig UDFs that are functions of primitive types IN to OUT. |
class |
TypedOutputEvalFunc<OUT>
Base class for Pig UDFs that are functions from Tuples to generic type OUT. |
Uses of EvalFunc in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators that return EvalFunc | |
---|---|
EvalFunc |
POUserFunc.getFunc()
|
Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with parameters of type EvalFunc | |
---|---|
POUserFunc(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
FuncSpec funcSpec,
EvalFunc func)
|
Uses of EvalFunc in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util with parameters of type EvalFunc | |
---|---|
static void |
MonitoredUDFExecutor.ErrorCallback.handleError(EvalFunc evalFunc,
Exception e)
|
static void |
MonitoredUDFExecutor.ErrorCallback.handleTimeout(EvalFunc evalFunc,
Exception e)
|
Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util with parameters of type EvalFunc | |
---|---|
MonitoredUDFExecutor(EvalFunc udf)
|
Uses of EvalFunc in org.apache.pig.builtin |
---|
Subclasses of EvalFunc in org.apache.pig.builtin | |
---|---|
class |
ABS
ABS implements a binding to the Java function Math.abs(double) for computing the
absolute value of the argument. |
class |
ACOS
ACOS implements a binding to the Java function Math.acos(double) for computing the
arc cosine of value of the argument. |
class |
AddDuration
AddDuration returns the result of a DateTime object plus a Duration object |
class |
AlgebraicBigDecimalMathBase
Core logic for applying an SUM function to a bag of BigDecimals. |
static class |
AlgebraicBigDecimalMathBase.Final
|
static class |
AlgebraicBigDecimalMathBase.Intermediate
|
class |
AlgebraicBigIntegerMathBase
Core logic for applying an SUM function to a bag of BigIntegers. |
static class |
AlgebraicBigIntegerMathBase.Final
|
static class |
AlgebraicBigIntegerMathBase.Intermediate
|
class |
AlgebraicByteArrayMathBase
Core logic for applying an accumulative/algebraic math function to a bag of doubles. |
static class |
AlgebraicByteArrayMathBase.Final
|
static class |
AlgebraicByteArrayMathBase.Initial
|
static class |
AlgebraicByteArrayMathBase.Intermediate
|
class |
AlgebraicDoubleMathBase
Core logic for applying an accumulative/algebraic math function to a bag of doubles. |
static class |
AlgebraicDoubleMathBase.Final
|
static class |
AlgebraicDoubleMathBase.Intermediate
|
class |
AlgebraicFloatMathBase
Core logic for applying an accumulative/algebraic math function to a bag of Floats. |
static class |
AlgebraicFloatMathBase.Final
|
static class |
AlgebraicFloatMathBase.Intermediate
|
class |
AlgebraicIntMathBase
Core logic for applying an accumulative/algebraic math function to a bag of doubles. |
static class |
AlgebraicIntMathBase.Final
|
static class |
AlgebraicIntMathBase.Intermediate
|
class |
AlgebraicLongMathBase
Core logic for applying an accumulative/algebraic math function to a bag of Longs. |
static class |
AlgebraicLongMathBase.Final
|
static class |
AlgebraicLongMathBase.Intermediate
|
static class |
AlgebraicMathBase.Final<T>
|
static class |
AlgebraicMathBase.Intermediate
|
class |
ARITY
Deprecated. Use SIZE instead. |
class |
ASIN
ASIN implements a binding to the Java function Math.asin(double) for computing the
arc sine of value of the argument. |
class |
Assert
|
class |
ATAN
ATAN implements a binding to the Java function Math.atan(double) for computing the
arc tangent of value of the argument. |
class |
AVG
Generates the average of a set of values. |
static class |
AVG.Final
|
static class |
AVG.Initial
|
static class |
AVG.Intermediate
|
class |
BagSize
This method should never be used directly, use SIZE . |
class |
BagToString
Flatten a bag into a string. |
class |
BagToTuple
Flatten a bag into a tuple. |
class |
Base
base class for math udfs |
class |
BigDecimalAbs
|
class |
BigDecimalAvg
This method should never be used directly, use AVG . |
static class |
BigDecimalAvg.Final
|
static class |
BigDecimalAvg.Initial
|
static class |
BigDecimalAvg.Intermediate
|
class |
BigDecimalMax
This method should never be used directly, use MAX . |
static class |
BigDecimalMax.Final
|
static class |
BigDecimalMax.Intermediate
|
class |
BigDecimalMin
This method should never be used directly, use MIN . |
static class |
BigDecimalMin.Final
|
static class |
BigDecimalMin.Intermediate
|
class |
BigDecimalSum
This method should never be used directly, use SUM . |
static class |
BigDecimalSum.Final
|
static class |
BigDecimalSum.Intermediate
|
class |
BigIntegerAbs
|
class |
BigIntegerAvg
This method should never be used directly, use AVG . |
static class |
BigIntegerAvg.Final
|
static class |
BigIntegerAvg.Initial
|
static class |
BigIntegerAvg.Intermediate
|
class |
BigIntegerMax
This method should never be used directly, use MAX . |
static class |
BigIntegerMax.Final
|
static class |
BigIntegerMax.Intermediate
|
class |
BigIntegerMin
This method should never be used directly, use MIN . |
static class |
BigIntegerMin.Final
|
static class |
BigIntegerMin.Intermediate
|
class |
BigIntegerSum
This method should never be used directly, use SUM . |
static class |
BigIntegerSum.Final
|
static class |
BigIntegerSum.Intermediate
|
class |
Bloom
Use a Bloom filter build previously by BuildBloom. |
class |
BuildBloom
Build a bloom filter for use later in Bloom. |
static class |
BuildBloom.Final
|
static class |
BuildBloom.Initial
|
static class |
BuildBloom.Intermediate
|
class |
BuildBloomBase<T>
A Base class for BuildBloom and its Algebraic implementations. |
class |
CBRT
CBRT implements a binding to the Java function Math.cbrt(double) for computing the
cube root of the argument. |
class |
CEIL
CEIL implements a binding to the Java function Math.ceil(double) . |
class |
CONCAT
Generates the concatenation of two or more arguments. |
class |
ConstantSize
This method should never be used directly, use SIZE . |
class |
COR
Computes the correlation between sets of data. |
static class |
COR.Final
|
static class |
COR.Initial
|
static class |
COR.Intermed
|
class |
COS
COS implements a binding to the Java function Math.cos(double) . |
class |
COSH
COSH implements a binding to the Java function Math.cosh(double) . |
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. |
static class |
COUNT_STAR.Final
|
static class |
COUNT_STAR.Initial
|
static class |
COUNT_STAR.Intermediate
|
static class |
COUNT.Final
|
static class |
COUNT.Initial
|
static class |
COUNT.Intermediate
|
class |
COV
Computes the covariance between sets of data. |
static class |
COV.Final
|
static class |
COV.Initial
|
static class |
COV.Intermed
|
class |
CubeDimensions
Produces a DataBag with all combinations of the argument tuple members as in a data cube. |
class |
CurrentTime
|
class |
DateTimeMax
This method should never be used directly, use MAX . |
static class |
DateTimeMax.Final
|
static class |
DateTimeMax.Initial
|
static class |
DateTimeMax.Intermediate
|
class |
DateTimeMin
This method should never be used directly, use MAX . |
static class |
DateTimeMin.Final
|
static class |
DateTimeMin.Initial
|
static class |
DateTimeMin.Intermediate
|
class |
DaysBetween
DaysBetween returns the number of days between two DateTime objects |
class |
DIFF
DIFF takes two bags as arguments and compares them. |
class |
Distinct
Find the distinct set of tuples in a bag. |
static class |
Distinct.Final
|
static class |
Distinct.Initial
|
static class |
Distinct.Intermediate
|
class |
DoubleAvg
This method should never be used directly, use AVG . |
static class |
DoubleAvg.Final
|
static class |
DoubleAvg.Initial
|
static class |
DoubleAvg.Intermediate
|
class |
DoubleBase
base class for math udfs that return Double value |
static class |
DoubleMax.Final
|
static class |
DoubleMax.Intermediate
|
static class |
DoubleMin.Final
|
static class |
DoubleMin.Intermediate
|
class |
DoubleRound
Given a single data atom it Returns the closest long to the argument. |
class |
DoubleRoundTo
ROUND_TO safely rounds a number to a given precision by using an intermediate BigDecimal. |
class |
DoubleSum
This method should never be used directly, use SUM . |
static class |
DoubleSum.Final
|
static class |
DoubleSum.Intermediate
|
class |
ENDSWITH
Pig UDF to test input tuple.get(0) against tuple.get(1)
to determine if the first argument ends with the string in the second. |
class |
EqualsIgnoreCase
Compares two Strings ignoring case considerations. |
class |
EXP
Given a single data atom it returns the Euler's number e raised to the power of input |
class |
FloatAbs
|
class |
FloatAvg
This method should never be used directly, use AVG . |
static class |
FloatAvg.Final
|
static class |
FloatAvg.Initial
|
static class |
FloatAvg.Intermediate
|
static class |
FloatMax.Final
|
static class |
FloatMax.Intermediate
|
static class |
FloatMin.Final
|
static class |
FloatMin.Intermediate
|
class |
FloatRound
ROUND implements a binding to the Java function Math.round(float) . |
class |
FloatRoundTo
ROUND_TO safely rounds a number to a given precision by using an intermediate BigDecimal. |
class |
FloatSum
This method should never be used directly, use SUM . |
class |
FLOOR
FLOOR implements a binding to the Java function Math.floor(double) . |
class |
FunctionWrapperEvalFunc
EvalFunc that wraps an implementation of the Function interface, which is passed as a String in the constructor. |
class |
GenericInvoker<T>
The generic Invoker class does all the common grunt work of setting up an invoker. |
class |
GetDay
GetDay extracts the day of a month from a DateTime object. |
class |
GetHour
GetHour extracts the hour of a day from a DateTime object. |
class |
GetMilliSecond
GetSecond extracts the millisecond of a second from a DateTime object. |
class |
GetMinute
GetMinute extracts the minute of an hour from a DateTime object. |
class |
GetMonth
GetMonth extracts the month of a year from a DateTime object. |
class |
GetSecond
GetSecond extracts the second of a minute from a DateTime object. |
class |
GetWeek
GetMonth extracts the week of a week year from a DateTime object. |
class |
GetWeekYear
GetMonth extracts the week year from a DateTime object. |
class |
GetYear
GetYear extracts the year from a DateTime object. |
class |
HoursBetween
HoursBetween returns the number of hours between two DateTime objects |
class |
INDEXOF
INDEXOF implements eval function to search for a string Example: A = load 'mydata' as (name); B = foreach A generate INDEXOF(name, ","); |
class |
IntAbs
ABS implements a binding to the Java function Math.abs(int) for computing the
absolute value of the argument. |
class |
IntAvg
This method should never be used directly, use AVG . |
static class |
IntAvg.Final
|
static class |
IntAvg.Initial
|
static class |
IntAvg.Intermediate
|
static class |
IntMax.Final
|
static class |
IntMax.Intermediate
|
static class |
IntMin.Final
|
static class |
IntMin.Intermediate
|
class |
IntSum
This method should never be used directly, use SUM . |
class |
INVERSEMAP
This UDF accepts a Map as input with values of any primitive data type. |
class |
InvokeForDouble
|
class |
InvokeForFloat
|
class |
InvokeForInt
|
class |
InvokeForLong
|
class |
InvokeForString
|
class |
InvokerGenerator
|
class |
IsEmpty
Determine whether a bag or map is empty. |
class |
KEYSET
This UDF takes a Map and returns a Bag containing the keyset. |
class |
LAST_INDEX_OF
string.INSTR implements eval function to search for the last occurrence of a string Returns null on error Example:
A = load 'mydata' as (name);
B = foreach A generate LASTINDEXOF(name, ",");
|
class |
LCFIRST
lower-case the first character of a string |
class |
LOG
LOG implements a binding to the Java function Math.log(double) . |
class |
LOG10
LOG10 implements a binding to the Java function Math.log10(double) . |
class |
LongAbs
|
class |
LongAvg
This method should never be used directly, use AVG . |
static class |
LongAvg.Final
|
static class |
LongAvg.Initial
|
static class |
LongAvg.Intermediate
|
static class |
LongMax.Final
|
static class |
LongMax.Intermediate
|
static class |
LongMin.Final
|
static class |
LongMin.Intermediate
|
class |
LongSum
This method should never be used directly, use SUM . |
static class |
LongSum.Final
|
static class |
LongSum.Intermediate
|
class |
LOWER
LOWER implements eval function to convert a string to lower case Example: A = load 'mydata' as (name); B = foreach A generate LOWER(name); |
class |
LTRIM
Returns a string, with only leading whitespace omitted. |
class |
MapSize
This method should never be used directly, use SIZE . |
static class |
MAX.Final
|
static class |
MAX.Intermediate
|
class |
MilliSecondsBetween
MilliSecondsBetween returns the number of milliseconds between two DateTime objects |
static class |
MIN.Final
|
static class |
MIN.Intermediate
|
class |
MinutesBetween
MinutesBetween returns the number of minutes between two DateTime objects |
class |
MonthsBetween
MonthsBetween returns the number of months between two DateTime objects |
class |
PluckTuple
This is a UDF which allows the user to specify a string prefix, and then filter for the columns in a relation that begin with that prefix. |
class |
RANDOM
Return a random double value. |
class |
REGEX_EXTRACT
Syntax: String RegexExtract(String expression, String regex, int match_index) .
Input:
expression -source string .
regex -regular expression .
match_index -index of the group to extract .
Output:
extracted group, if fail, return null .
Matching strategy:
Try to only match the first sequence by using Matcher.find() instead of
Matcher.matches() (default useMatches=false).
DEFINE NON_GREEDY_EXTRACT REGEX_EXTRACT('true');
|
class |
REGEX_EXTRACT_ALL
Syntax: String RegexExtractAll(String expression, String regex) .
Input:
expression -source string .
regex -regular expression .
Output:
A tuple of matched strings .
Matching strategy:
Trying to match the entire input by using Matcher.matches() instead of
Matcher.find() (default useMatches=true).
DEFINE GREEDY_EXTRACT REGEX_EXTRACT_ALL('false');
|
class |
REPLACE
REPLACE implements eval function to replace part of a string. |
class |
RollupDimensions
Produces a DataBag with hierarchy of values (from the most detailed level of aggregation to most general level of aggregation) of the specified dimensions For example, (a, b, c) will produce the following bag: |
class |
ROUND
ROUND implements a binding to the Java function Math.round(double) . |
class |
ROUND_TO
ROUND_TO safely rounds a number to a given precision by using an intermediate BigDecimal. |
class |
RTRIM
Returns a string, with only tailing whitespace omitted. |
class |
SecondsBetween
SecondsBetween returns the number of seconds between two DateTime objects |
class |
SIN
SIN implements a binding to the Java function Math.sin(double) . |
class |
SINH
SINH implements a binding to the Java function Math.sinh(double) . |
class |
SIZE
Generates the size of the argument passed to it. |
class |
SQRT
SQRT implements a binding to the Java function Math.sqrt(double) . |
class |
STARTSWITH
Pig UDF to test input tuple.get(0) against tuple.get(1)
to determine if the first argument starts with the string in the second. |
class |
StringConcat
This method should never be used directly, use CONCAT . |
class |
StringMax
This method should never be used directly, use MAX . |
static class |
StringMax.Final
|
static class |
StringMax.Initial
|
static class |
StringMax.Intermediate
|
class |
StringMin
This method should never be used directly, use MIN . |
static class |
StringMin.Final
|
static class |
StringMin.Initial
|
static class |
StringMin.Intermediate
|
class |
StringSize
This method should never be used directly, use SIZE . |
class |
STRSPLIT
Wrapper around Java's String.split input tuple: first column is assumed to have a string to split; the optional second column is assumed to have the delimiter or regex to split on; if not provided, it's assumed to be '\s' (space) the optional third column may provide a limit to the number of results. If limit is not provided, 0 is assumed, as per Java's split(). |
class |
SUBSTRING
SUBSTRING implements eval function to get a part of a string. |
class |
SUBTRACT
SUBTRACT takes two bags as arguments and returns a new bag composed of tuples of first bag not in the second bag. If null, bag arguments are replaced by empty bags. |
class |
SubtractDuration
SubtractDuration returns the result of a DateTime object plus a Duration object |
class |
SUM
Generates the sum of a set of values. |
static class |
SUM.Final
|
static class |
SUM.Intermediate
|
class |
TAN
TAN implements a binding to the Java function Math.tan(double) . |
class |
TANH
TANH implements a binding to the Java function Math.tanh(double) . |
class |
TOBAG
This class takes a list of items and puts them into a bag T = foreach U generate TOBAG($0, $1, $2); It's like saying this: T = foreach U generate {($0), ($1), ($2)} All arguments that are not of tuple type are inserted into a tuple before being added to the bag. |
class |
ToDate
ToDate converts the ISO or the customized string or the Unix timestamp to the DateTime object. |
class |
ToDate2ARGS
This method should never be used directly, use ToDate . |
class |
ToDate3ARGS
This method should never be used directly, use ToDate . |
class |
ToDateISO
This method should never be used directly, use ToDate . |
class |
TOKENIZE
Given a chararray as an argument, this method will split the chararray and return a bag with a tuple for each chararray that results from the split. |
class |
TOMAP
This class makes a map out of the parameters passed to it T = foreach U generate TOMAP($0, $1, $2, $3); It generates a map $0->1, $2->$3 |
class |
ToMilliSeconds
ToMilliSeconds converts the DateTime to the number of milliseconds that have passed since January 1, 1970 00:00:00.000 GMT. |
class |
TOP
Top UDF accepts a bag of tuples and returns top-n tuples depending upon the tuple field value of type long. |
static class |
TOP.Final
|
static class |
TOP.Initial
|
static class |
TOP.Intermed
|
class |
ToString
ToString converts the DateTime object of the ISO or the customized string. |
class |
TOTUPLE
This class makes a tuple out of the parameter T = foreach U generate TOTUPLE($0, $1, $2); It generates a tuple containing $0, $1, and $2 |
class |
ToUnixTime
ToUnixTime converts the DateTime to the Unix Time Long |
class |
TRIM
Returns a string, with leading and trailing whitespace omitted. |
class |
TupleSize
This method should never be used directly, use SIZE . |
class |
UCFIRST
upper-case the first character of a string |
class |
UPPER
UPPER implements eval function to convert a string to upper case Example: A = load 'mydata' as (name); B = foreach A generate UPPER(name); |
class |
VALUELIST
This UDF takes a Map and returns a Bag containing the values from map. |
class |
VALUESET
This UDF takes a Map and returns a Tuple containing the value set. |
class |
WeeksBetween
WeeksBetween returns the number of weeks between two DateTime objects |
class |
YearsBetween
YearsBetween returns the number of years between two DateTime objects |
Uses of EvalFunc in org.apache.pig.impl.builtin |
---|
Subclasses of EvalFunc in org.apache.pig.impl.builtin | |
---|---|
class |
FindQuantiles
|
class |
GetMemNumRows
UDF to get memory size of a tuple and extracts number of rows value from special tuple created by PoissonSampleLoader It is used by skewed join. |
class |
GFAny
built-in grouping function; permits system to choose any grouping. |
class |
GFCross
|
class |
GFReplicate
|
class |
IdentityColumn
Returns the input, used by DuplicateForEachColumnRewrite to rewrite duplicate columns in ForEach. |
class |
PartitionSkewedKeys
Partition reducers for skewed keys. |
class |
ReadScalars
ReadScalars reads a line from a file and returns it as its value. |
class |
StreamingUDF
|
Uses of EvalFunc in org.apache.pig.piggybank.evaluation |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation | |
---|---|
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. |
static class |
ExtremalTupleByNthField.HelperClass
Utility classes and methods |
class |
IsDouble
This UDF is used to check whether the String input is a Double. |
class |
IsFloat
This UDF is used to check whether the String input is a Float. |
class |
IsInt
This UDF is used to check whether the String input is an Integer. |
class |
IsLong
This UDF is used to check whether the String input is a Long. |
class |
IsNumeric
This UDF is used to check if a String is numeric. |
class |
MaxTupleBy1stField
MaxTupleBy1stField UDF returns a tuple with max value of the first field in a given bag. |
static class |
MaxTupleBy1stField.Final
|
static class |
MaxTupleBy1stField.Initial
|
static class |
MaxTupleBy1stField.Intermediate
|
class |
Over
Given an aggregate function, a bag, and possibly a window definition, produce output that matches SQL OVER. |
class |
Stitch
Given a set of bags, stitch them together tuple by tuple. |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime | |
---|---|
class |
DiffDate
Syntax: int DiffDate(String yyyymmdd1, String yyyymmdd2) .
Input:
date string in "yyyymmdd" format .
Output:
(date1-date2) in days, can be negative .
|
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime.convert |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime.convert | |
---|---|
class |
CustomFormatToISO
CustomFormatToISO converts arbitrary date formats to ISO format. |
class |
ISOToUnix
ISOToUnix converts ISO8601 datetime strings to Unix Time Longs |
class |
UnixToISO
UnixToISO converts Unix Time Long datetimes to ISO8601 datetime strings |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime.diff |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime.diff | |
---|---|
class |
ISODaysBetween
ISODaysBetween returns the number of days between two ISO8601 datetimes as a Long |
class |
ISOHoursBetween
ISOHoursBetween returns the number of hours between two ISO8601 datetimes as a Long |
class |
ISOMinutesBetween
ISOMinutesBetween returns the number of minutes between two ISO8601 datetimes as a Long |
class |
ISOMonthsBetween
ISOMonthsBetween returns the number of months between two ISO8601 datetimes as a Long |
class |
ISOSecondsBetween
ISOSecondsBetween returns the number of seconds between two ISO8601 datetimes as a Long |
class |
ISOYearsBetween
|
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime.truncate |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.datetime.truncate | |
---|---|
class |
ISOToDay
ISOToDay truncates an ISO8601 datetime string to the precision of the day field Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 |
class |
ISOToHour
ISOToHour truncates an ISO8601 datetime string to the precision of the hour field Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 |
class |
ISOToMinute
ISOToMinute truncates an ISO8601 datetime string to the precision of the minute field Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 |
class |
ISOToMonth
ISOToMonth truncates an ISO8601 datetime string to the precision of the month field Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 |
class |
ISOToSecond
ISOToSecond truncates an ISO8601 datetime string to the precision of the second field Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 |
class |
ISOToWeek
ISOToWeek truncates an ISO8601 datetime string to the precision of the day field, for the first day of the week of the datetime. |
class |
ISOToYear
|
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.decode |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.decode | |
---|---|
class |
Bin
Syntax: String Bin(arithmetic_expression, string1, ,..., stringN, sentinelN, default_string) .
Logic:
if (arithmetic_expression<=sentinel1) return string1; |
class |
BinCond
Syntax: String BinCond(boolean_expression1, mapping_string1, ..., boolean_expressionN, mapping_stringN, other_string) .
Logic:
if (boolean_expression1) return mapping_string1; |
class |
Decode
Syntax: String Decode(expression, value1, mapping_string1, ..., valueN, mapping_stringN, other_string) .
Logic:
if (expression==value1) return mapping_string1; |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.math |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.math | |
---|---|
class |
ATAN2
math.ATAN2 implements a binding to the Java function Math.atan2(double,double) . |
class |
copySign
math.copySign implements a binding to the Java function Math.copySign(double,double) . |
class |
DoubleAbs
Deprecated. Use DoubleAbs |
class |
DoubleCopySign
math.copySign implements a binding to the Java function Math.copySign(double,double) . |
class |
DoubleDoubleBase
base class for math udfs that return Double value |
class |
DoubleGetExponent
math.getExponent implements a binding to the Java function Math.getExponent(double) . |
class |
DoubleMax
math.max implements a binding to the Java function Math.max(int,int) for computing the
the max value of the arguments. |
class |
DoubleMin
math.min implements a binding to the Java function Math.min(int,int) for computing the
the min value of the arguments. |
class |
DoubleNextAfter
math.nextAfter implements a binding to the Java function Math.nextAfter(double,double) . |
class |
DoubleNextup
math.NEXTUP implements a binding to the Java function Math.nextUp(double) . |
class |
DoubleSignum
math.SIGNUM implements a binding to the Java function Math.signum(double) . |
class |
DoubleUlp
math.ULP implements a binding to the Java function Math.ulp(double) . |
class |
EXPM1
math.EXPM1 implements a binding to the Java function Math.expm1(double) . |
class |
FloatCopySign
math.copySign implements a binding to the Java function Math.copySign(float,float) . |
class |
FloatGetExponent
math.getExponent implements a binding to the Java function Math.getExponent(double) . |
class |
FloatMax
math.max implements a binding to the Java function Math.max(int,int) for computing the
the max value of the arguments. |
class |
FloatMin
math.min implements a binding to the Java function Math.min(int,int) for computing the
the min value of the arguments. |
class |
FloatNextAfter
math.nextAfter implements a binding to the Java function Math.nextAfter(double,double) . |
class |
FloatNextup
math.NEXTUP implements a binding to the Java function Math.nextUp(double) . |
class |
FloatSignum
math.SIGNUM implements a binding to the Java function Math.signum(float) . |
class |
FloatUlp
math.ULP implements a binding to the Java function Math.ulp(float) . |
class |
getExponent
math.getExponent implements a binding to the Java function Math.getExponent(double) . |
class |
HYPOT
math.HYPOT implements a binding to the Java function Math.hypot(double,double) . |
class |
IEEEremainder
math.IEEEremainder implements a binding to the Java function Math.IEEEremainder(double,double) . |
class |
IntMax
math.max implements a binding to the Java function Math.max(int,int) for computing the
the max value of the arguments. |
class |
IntMin
math.min implements a binding to the Java function Math.min(int,int) for computing the
the min value of the arguments. |
class |
LOG1P
math.LOG1P implements a binding to the Java function Math.log1p(double) . |
class |
LongMax
math.max implements a binding to the Java function Math.max(long,long) for computing the
the max value of the arguments. |
class |
LongMin
math.min implements a binding to the Java function Math.min(long,long) for computing the
the min value of the arguments. |
class |
MAX
math.MAX implements a binding to the Java function Math.max(double,double) . |
class |
MIN
math.MIN implements a binding to the Java function Math.min(double,double) . |
class |
nextAfter
math.nextAfter implements a binding to the Java function Math.nextAfter(double,double) . |
class |
NEXTUP
math.NEXTUP implements a binding to the Java function Math.nextUp(double) . |
class |
POW
math.POW implements a binding to the Java function Math.pow(double,double) . |
class |
RINT
math.RINT implements a binding to the Java function Math.rint(double) . |
class |
SCALB
math.SCALB implements a binding to the Java function Math.scalb(double,int) . |
class |
SIGNUM
math.SIGNUM implements a binding to the Java function Math.signum(double) . |
class |
toDegrees
math.toDegrees implements a binding to the Java function Math.toDegrees(double) . |
class |
toRadians
math.toRadians implements a binding to the Java function Math.toRadians(double) . |
class |
ULP
math.ULP implements a binding to the Java function Math.ulp(double) . |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.string |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.string | |
---|---|
class |
HashFNV
Syntax: long HashFNV(String string_to_hash, [int mod]) .
|
class |
HashFNV1
Implementation for HashFNV which takes 1 parameter |
class |
HashFNV2
Implementation for HashFNV which takes 2 parameter |
class |
LASTINDEXOF
Deprecated. Use LAST_INDEX_OF |
class |
LcFirst
Deprecated. Use LCFIRST |
class |
LENGTH
string.LENGTH implements eval function to find length of a string Example: register piggybank.jar; A = load 'mydata' as (name); B = foreach A generate string.LENGTH(name); dump B; |
class |
LookupInFiles
Syntax: int lookupInFiles(String expression,... |
class |
RegexExtract
Deprecated. Use REGEX_EXTRACT |
class |
RegexExtractAll
Deprecated. Use REGEX_EXTRACT_ALL |
class |
RegexMatch
Syntax: int RegexMatch(String expression, String regex) .
Output:
return 1 if expression contains regex, 0 otherwise .
|
class |
Reverse
|
class |
Split
Deprecated. Use STRSPLIT |
class |
Stuff
Given a string, this UDF replaces a substring given its starting index and length with the given replacement string. |
class |
Trim
Deprecated. Use TRIM |
class |
UcFirst
Deprecated. Use UCFIRST |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.util |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.util | |
---|---|
class |
SearchQuery
This small UDF takes a search engine URL (Google/Yahoo/AOL/Live) containing the search query and extracts it. |
class |
ToBag
Deprecated. Use TOBAG |
class |
Top
Deprecated. Use TOP |
static class |
Top.Final
Deprecated. |
static class |
Top.Initial
Deprecated. |
static class |
Top.Intermed
Deprecated. |
class |
ToTuple
Deprecated. Use TOTUPLE |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.util.apachelogparser |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.util.apachelogparser | |
---|---|
class |
DateExtractor
DateExtractor has four different constructors which each allow for different functionality. |
class |
HostExtractor
HostExtractor takes a url and returns the host. |
class |
SearchEngineExtractor
SearchEngineExtractor takes a url string and extracts the search engine. |
class |
SearchTermExtractor
SearchTermExtractor takes a url string and extracts the search terms. |
Uses of EvalFunc in org.apache.pig.piggybank.evaluation.xml |
---|
Subclasses of EvalFunc in org.apache.pig.piggybank.evaluation.xml | |
---|---|
class |
XPath
XPath is a function that allows for text extraction from xml |
Uses of EvalFunc in org.apache.pig.scripting.groovy |
---|
Uses of EvalFunc in org.apache.pig.scripting.jruby |
---|
Subclasses of EvalFunc in org.apache.pig.scripting.jruby | |
---|---|
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.AlgebraicFunctionWrapper<T>
This is a lightweight wrapper shell that registers information on the method being called, and provides the initializer that the static Algebraic classes (Initial, Intermed, Final) will use to execute. |
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.BagJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.ChararrayJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.ChararrayJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.DataByteArrayJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.DataByteArrayJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.DoubleJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.DoubleJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.Final<T>
This class invokes the final method on the given Ruby class. |
static class |
JrubyAlgebraicEvalFunc.FloatJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.FloatJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.Initial
This class invokes the initial method on the given Ruby class. |
static class |
JrubyAlgebraicEvalFunc.IntegerJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.IntegerJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.Intermed
This class invokes the intermed method on the given Ruby class. |
static class |
JrubyAlgebraicEvalFunc.LongJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.LongJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.MapJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.MapJrubyAlgebraicEvalFunc.Final
|
static class |
JrubyAlgebraicEvalFunc.TupleJrubyAlgebraicEvalFunc
|
static class |
JrubyAlgebraicEvalFunc.TupleJrubyAlgebraicEvalFunc.Final
|
class |
JrubyEvalFunc
This class serves at the bridge between Ruby methods that are registered with and extend PigUdf, and their execution in Pig. |
Uses of EvalFunc in org.apache.pig.scripting.js |
---|
Subclasses of EvalFunc in org.apache.pig.scripting.js | |
---|---|
class |
JsFunction
|
Uses of EvalFunc in org.apache.pig.scripting.jython |
---|
Subclasses of EvalFunc in org.apache.pig.scripting.jython | |
---|---|
class |
JythonFunction
Python implementation of a Pig UDF Performs mappings between Python & Pig data structures |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |