org.apache.hadoop.hive.ql.exec

Class PTFPartition

java.lang.Object

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

Direct Known Subclasses:

PTFRollingPartition

public class PTFPartition
extends 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(org.apache.hadoop.conf.Configuration cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI)
protected	PTFPartition(org.apache.hadoop.conf.Configuration cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, boolean createElemContainer)

Method Summary

Methods

Modifier and Type	Method and Description
void	append(Object o)
void	close()
static PTFPartition	create(org.apache.hadoop.conf.Configuration cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI)
static PTFRollingPartition	createRolling(org.apache.hadoop.conf.Configuration cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, int precedingSpan, int followingSpan)
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

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(org.apache.hadoop.conf.Configuration cfg,
            SerDe serDe,
            StructObjectInspector inputOI,
            StructObjectInspector outputOI)
                throws HiveException

Throws:

HiveException

PTFPartition

protected PTFPartition(org.apache.hadoop.conf.Configuration cfg,
            SerDe serDe,
            StructObjectInspector inputOI,
            StructObjectInspector outputOI,
            boolean createElemContainer)
                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 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(org.apache.hadoop.conf.Configuration cfg,
                  SerDe serDe,
                  StructObjectInspector inputOI,
                  StructObjectInspector outputOI)
                           throws HiveException

Throws:

HiveException

createRolling

public static PTFRollingPartition createRolling(org.apache.hadoop.conf.Configuration cfg,
                                SerDe serDe,
                                StructObjectInspector inputOI,
                                StructObjectInspector outputOI,
                                int precedingSpan,
                                int followingSpan)
                                         throws HiveException

Throws:

HiveException

setupPartitionOutputOI

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

Throws:

SerDeException