public class PTFRollingPartition extends PTFPartition
PTFPartition.PTFPartitionIterator<T>
LOG
Modifier | Constructor and Description |
---|---|
protected |
PTFRollingPartition(org.apache.hadoop.conf.Configuration cfg,
AbstractSerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI,
int startPos,
int endPos) |
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() |
create, createRolling, getInputOI, getOutputOI, getSerDe, range, setupPartitionOutputOI
protected PTFRollingPartition(org.apache.hadoop.conf.Configuration cfg, AbstractSerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, int startPos, int endPos) throws HiveException
HiveException
public void reset() throws HiveException
reset
in class PTFPartition
HiveException
public Object getAt(int i) throws HiveException
getAt
in class PTFPartition
HiveException
public void append(Object o) throws HiveException
append
in class PTFPartition
HiveException
public Object nextOutputRow() throws HiveException
HiveException
public boolean processedAllRows()
public int rowToProcess(WindowFrameDef wFrameDef)
wFrameDef
- public int size()
size
in class PTFPartition
public PTFPartition.PTFPartitionIterator<Object> iterator() throws HiveException
iterator
in class PTFPartition
HiveException
public void close()
close
in class PTFPartition
Copyright © 2021 The Apache Software Foundation. All rights reserved.