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');
 
 

Author:

wvaughan

Field Summary

Fields inherited from class org.apache.pig.EvalFunc

log, pigLogger, reporter, returnType

Constructor Summary

InUDF()

Method Summary

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

getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, 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