public class PTFPartition
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
PTFPartition.PTFPartitionIterator<T> |
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
Modifier | Constructor and Description |
---|---|
protected |
PTFPartition(HiveConf cfg,
SerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI) |
Modifier and Type | Method and Description |
---|---|
void |
append(java.lang.Object o) |
void |
close() |
static PTFPartition |
create(HiveConf cfg,
SerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI) |
java.lang.Object |
getAt(int i) |
StructObjectInspector |
getInputOI() |
StructObjectInspector |
getOutputOI() |
SerDe |
getSerDe() |
PTFPartition.PTFPartitionIterator<java.lang.Object> |
iterator() |
PTFPartition.PTFPartitionIterator<java.lang.Object> |
range(int start,
int end) |
void |
reset() |
static StructObjectInspector |
setupPartitionOutputOI(SerDe serDe,
StructObjectInspector tblFnOI) |
int |
size() |
protected PTFPartition(HiveConf cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI) throws HiveException
HiveException
public void reset() throws HiveException
HiveException
public SerDe getSerDe()
public StructObjectInspector getInputOI()
public StructObjectInspector getOutputOI()
public java.lang.Object getAt(int i) throws HiveException
HiveException
public void append(java.lang.Object o) throws HiveException
HiveException
public int size()
public PTFPartition.PTFPartitionIterator<java.lang.Object> iterator() throws HiveException
HiveException
public PTFPartition.PTFPartitionIterator<java.lang.Object> range(int start, int end)
public void close()
public static PTFPartition create(HiveConf cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI) throws HiveException
HiveException
public static StructObjectInspector setupPartitionOutputOI(SerDe serDe, StructObjectInspector tblFnOI) throws SerDeException
SerDeException
Copyright © 2012 The Apache Software Foundation