org.apache.pig.builtin
Class LAST_INDEX_OF
java.lang.Object
org.apache.pig.EvalFunc<Integer>
org.apache.pig.builtin.LAST_INDEX_OF
public class LAST_INDEX_OF
- extends EvalFunc<Integer>
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, ",");
Methods inherited from class org.apache.pig.EvalFunc |
finish, getCacheFiles, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, isAsynchronous, progress, setPigLogger, setReporter, warn |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LAST_INDEX_OF
public LAST_INDEX_OF()
exec
public Integer exec(Tuple input)
throws IOException
- Finds the last location of a substring in a given string.
- Specified by:
exec
in class EvalFunc<Integer>
- Parameters:
input
- tuple:
- the string to process
- the substring to find
- Returns:
- last location of substring, or null in case of processing errors.
- Throws:
IOException
outputSchema
public Schema outputSchema(Schema input)
- Description copied from class:
EvalFunc
- Report the schema of the output of this UDF. Pig will make use of
this in error checking, optimization, and planning. The schema
of input data to this UDF is provided.
- Overrides:
outputSchema
in class EvalFunc<Integer>
- Parameters:
input
- Schema of the input
- Returns:
- Schema of the output
getArgToFuncMapping
public List<FuncSpec> getArgToFuncMapping()
throws FrontendException
- Description copied from class:
EvalFunc
- Allow a UDF to specify type specific implementations of itself. For example,
an implementation of arithmetic sum might have int and float implementations,
since integer arithmetic performs much better than floating point arithmetic. Pig's
typechecker will call this method and using the returned list plus the schema
of the function's input data, decide which implementation of the UDF to use.
- Overrides:
getArgToFuncMapping
in class EvalFunc<Integer>
- Returns:
- A List containing FuncSpec objects representing the EvalFunc class
which can handle the inputs corresponding to the schema in the objects. Each
FuncSpec should be constructed with a schema that describes the input for that
implementation. For example, the sum function above would return two elements in its
list:
- FuncSpec(this.getClass().getName(), new Schema(new Schema.FieldSchema(null, DataType.DOUBLE)))
- FuncSpec(IntSum.getClass().getName(), new Schema(new Schema.FieldSchema(null, DataType.INTEGER)))
This would indicate that the main implementation is used for doubles, and the special
implementation IntSum is used for ints.
- Throws:
FrontendException
Copyright © 2012 The Apache Software Foundation