EvalFunc.SchemaType
log, pigLogger, reporter, returnType
Constructor and Description |
---|
StringConcat() |
Modifier and Type | Method and Description |
---|---|
boolean |
allowCompileTimeCalculation()
Whether the UDF should be evaluated at compile time if all inputs are constant.
|
String |
exec(Tuple input)
This callback method must be implemented by all subclasses.
|
EvalFunc.SchemaType |
getSchemaType()
Returns the
EvalFunc.SchemaType of the EvalFunc. |
Schema |
outputSchema(Schema input)
Report the schema of the output of this UDF.
|
finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLoadCaster, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getShipFiles, isAsynchronous, needEndOfAllInputProcessing, progress, setEndOfAllInput, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public String exec(Tuple input) throws IOException
EvalFunc
exec
in class EvalFunc<String>
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<String>
input
- Schema of the inputpublic EvalFunc.SchemaType getSchemaType()
EvalFunc
EvalFunc.SchemaType
of the EvalFunc. User defined functions can override
this method to return EvalFunc.SchemaType.VARARG
. In this case the last FieldSchema
added to the Schema in EvalFunc.getArgToFuncMapping()
will be considered as a vararg field.getSchemaType
in class EvalFunc<String>
public boolean allowCompileTimeCalculation()
EvalFunc
allowCompileTimeCalculation
in class EvalFunc<String>
Copyright © 2007-2017 The Apache Software Foundation