public class GenericUDTFGetSplits extends GenericUDTF
Modifier and Type | Class and Description |
---|---|
static class |
GenericUDTFGetSplits.PlanFragment |
Modifier and Type | Field and Description |
---|---|
protected IntObjectInspector |
intOI |
protected org.apache.hadoop.mapred.JobConf |
jc |
protected StringObjectInspector |
stringOI |
Constructor and Description |
---|
GenericUDTFGetSplits() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Called to notify the UDTF that there are no more rows to process.
|
GenericUDTFGetSplits.PlanFragment |
createPlanFragment(String query,
int num) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits,
TezWork work,
Schema schema) |
StructObjectInspector |
initialize(ObjectInspector[] arguments)
Initialize this GenericUDTF.
|
void |
process(Object[] arguments)
Give a set of arguments for the UDTF to process.
|
configure, forward, initialize, setCollector
protected transient StringObjectInspector stringOI
protected transient IntObjectInspector intOI
protected transient org.apache.hadoop.mapred.JobConf jc
public StructObjectInspector initialize(ObjectInspector[] arguments) throws UDFArgumentException
GenericUDTF
initialize
in class GenericUDTF
arguments
- An array of ObjectInspectors for the argumentsUDFArgumentException
public void process(Object[] arguments) throws HiveException
GenericUDTF
process
in class GenericUDTF
arguments
- object array of argumentsHiveException
public GenericUDTFGetSplits.PlanFragment createPlanFragment(String query, int num) throws HiveException
HiveException
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits, TezWork work, Schema schema) throws IOException
IOException
public void close() throws HiveException
GenericUDTF
close
in class GenericUDTF
HiveException
Copyright © 2016 The Apache Software Foundation. All rights reserved.