public class SUBTRACT extends EvalFunc<DataBag>
The implementation assumes that both bags being passed to this function will fit entirely into memory simultaneously. If that is not the case the UDF will still function, but it will be very slow.
EvalFunc.SchemaType
log, pigLogger, reporter, returnType
Constructor and Description |
---|
SUBTRACT() |
Modifier and Type | Method and Description |
---|---|
DataBag |
exec(Tuple input)
Compares the two bag fields from input Tuple and returns a new bag composed of elements of first bag not in the second bag.
|
finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, isAsynchronous, outputSchema, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
Copyright © 2007-2012 The Apache Software Foundation