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

java.lang.Object
  org.apache.hadoop.hive.ql.exec.PTFPartition

public class PTFPartition
extends Object

Nested Class Summary

static interface

PTFPartition.PTFPartitionIterator<T>

Method Summary

void	append(Object o)
void	close()
static PTFPartition	create(HiveConf cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI)
Object	getAt(int i)
StructObjectInspector	getInputOI()
StructObjectInspector	getOutputOI()
SerDe	getSerDe()
PTFPartition.PTFPartitionIterator<Object>	iterator()
PTFPartition.PTFPartitionIterator<Object>	range(int start, int end)
void	reset()
static StructObjectInspector	setupPartitionOutputOI(SerDe serDe, StructObjectInspector tblFnOI)
int	size()

Methods inherited from class java.lang.Object

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

Method Detail

reset

public void reset()
           throws HiveException

Throws:

HiveException

getSerDe

public SerDe getSerDe()

getInputOI

public StructObjectInspector getInputOI()

getOutputOI

public StructObjectInspector getOutputOI()

getAt

public Object getAt(int i)
             throws HiveException

Throws:

HiveException

append

public void append(Object o)
            throws HiveException

Throws:

HiveException

size

public int size()

iterator

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

Throws:

HiveException

range

public PTFPartition.PTFPartitionIterator<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