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, AbstractSerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, int startPos, int endPos)

Method Summary

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(WindowFrameDef wFrameDef) Gets the next row index that the data within the window are available and can be processed
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,
                              AbstractSerDe serDe,
                              StructObjectInspector inputOI,
                              StructObjectInspector outputOI,
                              int startPos,
                              int endPos)
                       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(WindowFrameDef wFrameDef)

Gets the next row index that the data within the window are available and can be processed

Parameters:

wFrameDef -

Returns:

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