org.apache.hadoop.hive.ql.exec

Class PTFPartition

java.lang.Object

org.apache.hadoop.hive.ql.exec.PTFPartition

public class PTFPartition
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PTFPartition.PTFPartitionIterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PTFPartition(HiveConf cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static org.apache.commons.logging.Log LOG

Constructor Detail

PTFPartition

protected PTFPartition(HiveConf cfg,
                       SerDe serDe,
                       StructObjectInspector inputOI,
                       StructObjectInspector outputOI)
                throws HiveException

Throws:

HiveException

Method Detail

reset

public void reset()
           throws HiveException

Throws:

HiveException

getSerDe

public SerDe getSerDe()

getInputOI

public StructObjectInspector getInputOI()

getOutputOI

public StructObjectInspector getOutputOI()

getAt

public java.lang.Object getAt(int i)
                       throws HiveException

Throws:

HiveException

append

public void append(java.lang.Object o)
            throws HiveException

Throws:

HiveException

size

public int size()

iterator

public PTFPartition.PTFPartitionIterator<java.lang.Object> iterator()
                                                             throws HiveException

Throws:

HiveException

range

public PTFPartition.PTFPartitionIterator<java.lang.Object> range(int start,
                                                                 int end)

close

public void close()

create

public static PTFPartition create(HiveConf cfg,
                                  SerDe serDe,
                                  StructObjectInspector inputOI,
                                  StructObjectInspector outputOI)
                           throws HiveException

Throws:

HiveException

setupPartitionOutputOI

public static StructObjectInspector setupPartitionOutputOI(SerDe serDe,
                                                           StructObjectInspector tblFnOI)
                                                    throws SerDeException

Throws:

SerDeException