org.apache.hadoop.hive.ql.exec

Class PTFRollingPartition

java.lang.Object

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

org.apache.hadoop.hive.ql.exec.PTFRollingPartition

public class PTFRollingPartition
extends PTFPartition

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.exec.PTFPartition

PTFPartition.PTFPartitionIterator<T>

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.exec.PTFPartition

LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PTFRollingPartition(org.apache.hadoop.conf.Configuration cfg, SerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, int precedingSpan, int succeedingSpan)

Method Summary

Methods

Modifier and Type	Method and Description
void	append(Object o)
void	close()
Object	getAt(int i)
PTFPartition.PTFPartitionIterator<Object>	iterator()
Object	nextOutputRow()
boolean	processedAllRows()
void	reset()
int	rowToProcess(WindowFunctionDef wFn)
int	size()

Methods inherited from class org.apache.hadoop.hive.ql.exec.PTFPartition

create, createRolling, getInputOI, getOutputOI, getSerDe, range, setupPartitionOutputOI

Methods inherited from class java.lang.Object

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

Constructor Detail

PTFRollingPartition

protected PTFRollingPartition(org.apache.hadoop.conf.Configuration cfg,
                   SerDe serDe,
                   StructObjectInspector inputOI,
                   StructObjectInspector outputOI,
                   int precedingSpan,
                   int succeedingSpan)
                       throws HiveException

Throws:

HiveException

Method Detail

reset

public void reset()
           throws HiveException

Overrides:

reset in class PTFPartition

Throws:

HiveException

getAt

public Object getAt(int i)
             throws HiveException

Overrides:

getAt in class PTFPartition

Throws:

HiveException

append

public void append(Object o)
            throws HiveException

Overrides:

append in class PTFPartition

Throws:

HiveException

nextOutputRow

public Object nextOutputRow()
                     throws HiveException

Throws:

HiveException

processedAllRows

public boolean processedAllRows()

rowToProcess

public int rowToProcess(WindowFunctionDef wFn)

size

public int size()

Overrides:

size in class PTFPartition

iterator

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

Overrides:

iterator in class PTFPartition

Throws:

HiveException

close

public void close()

Overrides:

close in class PTFPartition