public static class WindowingTableFunction.HiveDecimalValueBoundaryScanner extends Object
Constructor and Description |
---|
WindowingTableFunction.HiveDecimalValueBoundaryScanner(BoundaryDef bndDef,
PTFInvocationSpec.Order order,
PTFExpressionDef 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.ValueBoundaryScanner |
getScanner(ValueBoundaryDef vbDef,
PTFInvocationSpec.Order order) |
boolean |
isEqual(Object v1,
Object v2) |
boolean |
isGreater(Object v1,
Object v2,
int amt) |
void |
reset(BoundaryDef bndDef) |
public WindowingTableFunction.HiveDecimalValueBoundaryScanner(BoundaryDef bndDef, PTFInvocationSpec.Order order, PTFExpressionDef expressionDef)
public void reset(BoundaryDef bndDef)
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.ValueBoundaryScanner getScanner(ValueBoundaryDef vbDef, PTFInvocationSpec.Order order) throws HiveException
HiveException
Copyright © 2017 The Apache Software Foundation. All rights reserved.