|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of EvalFunc in org.apache.pig |
---|
Subclasses of EvalFunc in org.apache.pig | |
---|---|
class |
FilterFunc
|
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 |
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 |
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 |
Base
base class for math udfs |
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 the first two 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 |
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 |
DoubleAbs
|
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 |
class |
DoubleMax
This method should never be used directly, use MAX . |
static class |
DoubleMax.Final
|
static class |
DoubleMax.Initial
|
static class |
DoubleMax.Intermediate
|
class |
DoubleMin
This method should never be used directly, use MIN . |
static class |
DoubleMin.Final
|
static class |
DoubleMin.Initial
|
static class |
DoubleMin.Intermediate
|
class |
DoubleRound
Given a single data atom it Returns the closest long to the argument. |
class |
DoubleSum
This method should never be used directly, use SUM . |
static class |
DoubleSum.Final
|
static class |
DoubleSum.Initial
|
static class |
DoubleSum.Intermediate
|
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
|
class |
FloatMax
This method should never be used directly, use MAX . |
static class |
FloatMax.Final
|
static class |
FloatMax.Initial
|
static class |
FloatMax.Intermediate
|
class |
FloatMin
This method should never be used directly, use MIN . |
static class |
FloatMin.Final
|
static class |
FloatMin.Initial
|
static class |
FloatMin.Intermediate
|
class |
FloatRound
ROUND implements a binding to the Java function Math.round(float) . |
class |
FloatSum
This method should never be used directly, use SUM . |
static class |
FloatSum.Final
|
static class |
FloatSum.Initial
|
static class |
FloatSum.Intermediate
|
class |
FLOOR
FLOOR implements a binding to the Java function Math.floor(double) . |
class |
GenericInvoker<T>
The generic Invoker class does all the common grunt work of setting up an invoker. |
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
|
class |
IntMax
This method should never be used directly, use MAX . |
static class |
IntMax.Final
|
static class |
IntMax.Initial
|
static class |
IntMax.Intermediate
|
class |
IntMin
This method should never be used directly, use MIN . |
static class |
IntMin.Final
|
static class |
IntMin.Initial
|
static class |
IntMin.Intermediate
|
class |
IntSum
This method should never be used directly, use SUM . |
static class |
IntSum.Final
|
static class |
IntSum.Initial
|
static class |
IntSum.Intermediate
|
class |
InvokeForDouble
|
class |
InvokeForFloat
|
class |
InvokeForInt
|
class |
InvokeForLong
|
class |
InvokeForString
|
class |
IsEmpty
Determine whether a bag or map is empty. |
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
|
class |
LongMax
This method should never be used directly, use MAX . |
static class |
LongMax.Final
|
static class |
LongMax.Initial
|
static class |
LongMax.Intermediate
|
class |
LongMin
This method should never be used directly, use MIN . |
static class |
LongMin.Final
|
static class |
LongMin.Initial
|
static class |
LongMin.Intermediate
|
class |
LongSum
This method should never be used directly, use SUM . |
static class |
LongSum.Final
|
static class |
LongSum.Initial
|
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 |
MapSize
This method should never be used directly, use SIZE . |
class |
MAX
Generates the maximum of a set of values. |
static class |
MAX.Final
|
static class |
MAX.Initial
|
static class |
MAX.Intermediate
|
class |
MIN
Generates the minimum of a set of values. |
static class |
MIN.Final
|
static class |
MIN.Initial
|
static class |
MIN.Intermediate
|
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 .
|
class |
REGEX_EXTRACT_ALL
Syntax: String RegexExtractAll(String expression, String regex) .
Input:
expression -source string .
regex -regular expression .
Output:
A tuple of matched strings .
|
class |
REPLACE
REPLACE implements eval function to replace part of a string. |
class |
ROUND
ROUND implements a binding to the Java function Math.round(double) . |
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 |
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 |
SUM
Generates the sum of a set of values. |
static class |
SUM.Final
|
static class |
SUM.Initial
|
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)} Output schema: The output schema for this udf depends on the schema of its arguments. |
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 |
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 |
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 |
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); |
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. |
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 |
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
|
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 Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Unix Time: http://en.wikipedia.org/wiki/Unix_time Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOToUnix org.apache.pig.piggybank.evaluation.datetime.convert.ISOToUnix(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
class |
UnixToISO
UnixToISO converts Unix Time Long datetimes to ISO8601 datetime strings Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Unix Time: http://en.wikipedia.org/wiki/Unix_time Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE UnixToISO org.apache.pig.piggybank.evaluation.datetime.convert.UnixToISO(); UnixIn = LOAD 'test2.tsv' USING PigStorage('\t') AS (dt:long); DESCRIBE UnixIn; UnixIn: {dt: long} DUMP UnixIn; (1231290421000L) (1233885962000L) (1236222303000L) toISO = FOREACH UnixIn GENERATE UnixToISO(dt) AS ISOTime:chararray; DESCRIBE toISO; toISO: {ISOTime: chararray} DUMP toISO; (2009-01-07T01:07:01.000Z) (2009-02-06T02:06:02.000Z) (2009-03-05T03:05:03.000Z) ... |
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 Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOYearsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween(); DEFINE ISOMonthsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween(); DEFINE ISODaysBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween(); DEFINE ISOHoursBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween(); DEFINE ISOMinutesBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween(); DEFINE ISOSecondsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
class |
ISOHoursBetween
ISOHoursBetween returns the number of hours between two ISO8601 datetimes as a Long Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOYearsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween(); DEFINE ISOMonthsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween(); DEFINE ISODaysBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween(); DEFINE ISOHoursBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween(); DEFINE ISOMinutesBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween(); DEFINE ISOSecondsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
class |
ISOMinutesBetween
ISOMinutesBetween returns the number of minutes between two ISO8601 datetimes as a Long Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOYearsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween(); DEFINE ISOMonthsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween(); DEFINE ISODaysBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween(); DEFINE ISOHoursBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween(); DEFINE ISOMinutesBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween(); DEFINE ISOSecondsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
class |
ISOMonthsBetween
ISOMonthsBetween returns the number of months between two ISO8601 datetimes as a Long Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOYearsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween(); DEFINE ISOMonthsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween(); DEFINE ISODaysBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween(); DEFINE ISOHoursBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween(); DEFINE ISOMinutesBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween(); DEFINE ISOSecondsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
class |
ISOSecondsBetween
ISOSecondsBetween returns the number of seconds between two ISO8601 datetimes as a Long Jodatime: http://joda-time.sourceforge.net/ ISO8601 Date Format: http://en.wikipedia.org/wiki/ISO_8601 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOYearsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween(); DEFINE ISOMonthsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween(); DEFINE ISODaysBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween(); DEFINE ISOHoursBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween(); DEFINE ISOMinutesBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween(); DEFINE ISOSecondsBetween org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
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 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOToYear org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear(); DEFINE ISOToMonth org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth(); DEFINE ISOToWeek org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek(); DEFINE ISOToDay org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay(); DEFINE ISOToHour org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour(); DEFINE ISOToMinute org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute(); DEFINE ISOToSecond org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
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 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOToYear org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear(); DEFINE ISOToMonth org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth(); DEFINE ISOToWeek org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek(); DEFINE ISOToDay org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay(); DEFINE ISOToHour org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour(); DEFINE ISOToMinute org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute(); DEFINE ISOToSecond org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
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 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOToYear org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear(); DEFINE ISOToMonth org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth(); DEFINE ISOToWeek org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek(); DEFINE ISOToDay org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay(); DEFINE ISOToHour org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour(); DEFINE ISOToMinute org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute(); DEFINE ISOToSecond org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
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 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOToYear org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear(); DEFINE ISOToMonth org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth(); DEFINE ISOToWeek org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek(); DEFINE ISOToDay org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay(); DEFINE ISOToHour org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour(); DEFINE ISOToMinute org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute(); DEFINE ISOToSecond org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
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 Example usage: REGISTER /Users/me/commiter/piggybank/java/piggybank.jar ; REGISTER /Users/me/commiter/piggybank/java/lib/joda-time-1.6.jar ; DEFINE ISOToYear org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear(); DEFINE ISOToMonth org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth(); DEFINE ISOToWeek org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek(); DEFINE ISOToDay org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay(); DEFINE ISOToHour org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour(); DEFINE ISOToMinute org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute(); DEFINE ISOToSecond org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond(); ISOin = LOAD 'test.tsv' USING PigStorage('\t') AS (dt:chararray, dt2:chararray); DESCRIBE ISOin; ISOin: {dt: chararray,dt2: chararray} DUMP ISOin; (2009-01-07T01:07:01.000Z,2008-02-01T00:00:00.000Z) (2008-02-06T02:06:02.000Z,2008-02-01T00:00:00.000Z) (2007-03-05T03:05:03.000Z,2008-02-01T00:00:00.000Z) ... |
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 |
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 |
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 |
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 |
LOG1P
math.LOG1P implements a binding to the Java function Math.log1p(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 |
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.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 |