public abstract class GenericUDTF
extends java.lang.Object
Constructor and Description |
---|
GenericUDTF() |
Modifier and Type | Method and Description |
---|---|
abstract void |
close()
Called to notify the UDTF that there are no more rows to process.
|
void |
configure(MapredContext mapredContext)
Additionally setup GenericUDTF with MapredContext before initializing.
|
protected void |
forward(java.lang.Object o)
Passes an output row to the collector.
|
abstract StructObjectInspector |
initialize(ObjectInspector[] argOIs)
Initialize this GenericUDTF.
|
abstract void |
process(java.lang.Object[] args)
Give a set of arguments for the UDTF to process.
|
void |
setCollector(Collector collector)
Associates a collector with this UDTF.
|
public void configure(MapredContext mapredContext)
context
- contextpublic abstract StructObjectInspector initialize(ObjectInspector[] argOIs) throws UDFArgumentException
argOIs
- An array of ObjectInspectors for the argumentsUDFArgumentException
public abstract void process(java.lang.Object[] args) throws HiveException
args
- object array of argumentsHiveException
public abstract void close() throws HiveException
HiveException
public final void setCollector(Collector collector)
collector
- protected final void forward(java.lang.Object o) throws HiveException
o
- HiveException
Copyright © 2012 The Apache Software Foundation