datafu.pig.util

Class InUDF

java.lang.Object

org.apache.pig.EvalFunc<java.lang.Boolean>

org.apache.pig.FilterFunc

datafu.pig.util.InUDF

Direct Known Subclasses:

In

public class InUDF
extends org.apache.pig.FilterFunc

Similar to the SQL IN function, this function provides a convenient way to filter using a logical disjunction over many values. Returns true when the first value of the tuple is contained within the remainder of the tuple. Example:

 
 define In datafu.pig.util.InUDF();
 -- cars: (alice, red), (bob, blue), (charlie, green), (dave, red);
 cars = LOAD cars AS (owner:chararray, color:chararray);

 -- cars: (alice, red), (bob, blue), (dave, red);
 red_blue_cars = FILTER cars BY In(color, 'red', 'blue');

 
 

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.EvalFunc

org.apache.pig.EvalFunc.SchemaType

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

Constructors

Constructor and Description
InUDF()

Method Summary

Modifier and Type	Method and Description
java.lang.Boolean	exec(org.apache.pig.data.Tuple input)

Methods inherited from class org.apache.pig.FilterFunc

finish

Methods inherited from class org.apache.pig.EvalFunc

allowCompileTimeCalculation, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, outputSchema, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InUDF

public InUDF()

Method Detail

exec

public java.lang.Boolean exec(org.apache.pig.data.Tuple input)
                       throws java.io.IOException

Specified by:

exec in class org.apache.pig.EvalFunc<java.lang.Boolean>

Throws:

java.io.IOException