public class StreamingUDF extends EvalFunc<java.lang.Object>
Modifier and Type | Class and Description |
---|---|
class |
StreamingUDF.ProcessKiller |
EvalFunc.SchemaType
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TURN_ON_OUTPUT_CAPTURING |
pigLogger, reporter, returnType
Constructor and Description |
---|
StreamingUDF(java.lang.String language,
java.lang.String filePath,
java.lang.String funcName,
java.lang.String outputSchemaString,
java.lang.String schemaLineNumber,
java.lang.String execType,
java.lang.String isIllustrate) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
exec(Tuple input)
This callback method must be implemented by all subclasses.
|
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, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn
public static final java.lang.String TURN_ON_OUTPUT_CAPTURING
public StreamingUDF(java.lang.String language, java.lang.String filePath, java.lang.String funcName, java.lang.String outputSchemaString, java.lang.String schemaLineNumber, java.lang.String execType, java.lang.String isIllustrate) throws StreamingUDFOutputSchemaException, ExecException
public java.lang.Object exec(Tuple input) throws java.io.IOException
EvalFunc
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<java.lang.Object>
input
- Schema of the inputCopyright © 2007-2012 The Apache Software Foundation