public static class WindowingTableFunction.HiveDecimalValueBoundaryScanner extends Object
Constructor and Description |
---|
HiveDecimalValueBoundaryScanner(BoundaryDef bndDef,
OrderExpressionDef expressionDef) |
Modifier and Type | Method and Description |
---|---|
protected int |
computeEnd(int rowIdx,
PTFPartition p) |
protected int |
computeEndCurrentRow(int rowIdx,
PTFPartition p) |
protected int |
computeEndFollowing(int rowIdx,
PTFPartition p) |
protected int |
computeEndPreceding(int rowIdx,
PTFPartition p) |
protected int |
computeStart(int rowIdx,
PTFPartition p) |
protected int |
computeStartCurrentRow(int rowIdx,
PTFPartition p) |
protected int |
computeStartFollowing(int rowIdx,
PTFPartition p) |
protected int |
computeStartPreceding(int rowIdx,
PTFPartition p) |
Object |
computeValue(Object row) |
static org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.SingleValueBoundaryScanner |
getScanner(ValueBoundaryDef vbDef) |
boolean |
isDistanceGreater(Object v1,
Object v2,
int amt)
Checks if the distance of v2 to v1 is greater than the given amt.
|
boolean |
isEqual(Object v1,
Object v2)
Checks if the values of v1 or v2 are the same.
|
void |
reset(BoundaryDef bndDef) |
public HiveDecimalValueBoundaryScanner(BoundaryDef bndDef, OrderExpressionDef expressionDef)
public boolean isDistanceGreater(Object v1, Object v2, int amt)
public boolean isEqual(Object v1, Object v2)
protected int computeStart(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeStartPreceding(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeStartCurrentRow(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeStartFollowing(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEnd(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEndPreceding(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEndCurrentRow(int rowIdx, PTFPartition p) throws HiveException
HiveException
protected int computeEndFollowing(int rowIdx, PTFPartition p) throws HiveException
HiveException
public Object computeValue(Object row) throws HiveException
HiveException
public static org.apache.hadoop.hive.ql.udf.ptf.WindowingTableFunction.SingleValueBoundaryScanner getScanner(ValueBoundaryDef vbDef) throws HiveException
HiveException
public void reset(BoundaryDef bndDef)
Copyright © 2016 The Apache Software Foundation. All rights reserved.