public class Partition extends Object
A partition can be partial, which means we don't know "yet" the total number of records that are part of this partition. Even for partial partitions, we know the number of rows that are part of current frame
Modifier and Type | Field and Description |
---|---|
double |
cume_dist |
int |
dense_rank |
double |
percent_rank |
int |
rank |
int |
row_number |
Constructor and Description |
---|
Partition() |
Modifier and Type | Method and Description |
---|---|
long |
getLength() |
long |
getRemaining() |
boolean |
isDone() |
boolean |
isFrameDone() |
void |
newFrame(long peers) |
int |
ntile(int numTiles) |
void |
rowAggregated() |
String |
toString() |
void |
updateLength(long length,
boolean partial) |
public int row_number
public int rank
public int dense_rank
public double percent_rank
public double cume_dist
public long getRemaining()
public long getLength()
public void updateLength(long length, boolean partial)
length
- number of rows in this partitionpartial
- if true, then length is not the full length of the partition but
just the number of rows in the current batchpublic void rowAggregated()
public void newFrame(long peers)
public boolean isDone()
public int ntile(int numTiles)
public boolean isFrameDone()
Copyright © 1970 The Apache Software Foundation. All rights reserved.