public class MonitoredUDFExecutor extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
MonitoredUDFExecutor.ErrorCallback
UDF authors can optionally extend this class and provide the class of their custom callbacks in the annotation
to perform their own handling of errors and timeouts.
|
Constructor and Description |
---|
MonitoredUDFExecutor(EvalFunc udf) |
Modifier and Type | Method and Description |
---|---|
Object |
monitorExec(Tuple input) |
void |
terminate()
This method *MUST* be called in the finish by POUserFunc.
|
public MonitoredUDFExecutor(EvalFunc udf)
public void terminate()
public Object monitorExec(Tuple input) throws IOException
IOException
Copyright © 2007-2017 The Apache Software Foundation