EvalFunc.SchemaType
log, pigLogger, reporter, returnType
Constructor and Description |
---|
InvokerGenerator(String className,
String methodName,
String argumentTypes) |
Modifier and Type | Method and Description |
---|---|
Object |
exec(Tuple input)
This callback method must be implemented by all subclasses.
|
protected void |
initialize() |
Schema |
outputSchema(Schema input)
Report the schema of the output of this UDF.
|
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, needEndOfAllInputProcessing, progress, setEndOfAllInput, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public Object exec(Tuple input) throws IOException
EvalFunc
exec
in class EvalFunc<Object>
input
- the Tuple to be processed.IOException
public Schema outputSchema(Schema input)
EvalFunc
The default implementation interprets the OutputSchema
annotation,
if one is present. Otherwise, it returns null
(no known output schema).
outputSchema
in class EvalFunc<Object>
input
- Schema of the inputprotected void initialize()
Copyright © 2007-2012 The Apache Software Foundation