@MonitoredUDF(timeUnit=SECONDS, duration=30, intDefault=10) public class StreamsProcessDatumExec extends datafu.pig.util.AliasableEvalFunc<org.apache.pig.data.DataBag>
Constructor and Description |
---|
StreamsProcessDatumExec(String... execArgs) |
Modifier and Type | Method and Description |
---|---|
org.apache.pig.data.DataBag |
exec(org.apache.pig.data.Tuple input) |
void |
finish() |
org.apache.pig.impl.logicalLayer.schema.Schema |
getOutputSchema(org.apache.pig.impl.logicalLayer.schema.Schema schema) |
getBag, getBoolean, getDouble, getDouble, getFieldAliases, getFloat, getFloat, getInteger, getInteger, getLong, getLong, getObject, getPosition, getPosition, getPrefixedAliasName, getString, getString, outputSchema
getContextProperties, getInstanceName, getInstanceProperties, setUDFContextSignature
public StreamsProcessDatumExec(String... execArgs) throws ClassNotFoundException
ClassNotFoundException
public org.apache.pig.data.DataBag exec(org.apache.pig.data.Tuple input) throws IOException
exec
in class org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>
IOException
public void finish()
finish
in class org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>
public org.apache.pig.impl.logicalLayer.schema.Schema getOutputSchema(org.apache.pig.impl.logicalLayer.schema.Schema schema)
getOutputSchema
in class datafu.pig.util.AliasableEvalFunc<org.apache.pig.data.DataBag>
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.