org.apache.hadoop.hbase.client.coprocessor
Class BigDecimalColumnInterpreter

java.lang.Object
  org.apache.hadoop.hbase.coprocessor.ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>
      org.apache.hadoop.hbase.client.coprocessor.BigDecimalColumnInterpreter

@InterfaceAudience.Public
@InterfaceStability.Evolving
public class BigDecimalColumnInterpreter
extends ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

ColumnInterpreter for doing Aggregation's with BigDecimal columns. This class is required at the RegionServer also.

Constructor Summary

BigDecimalColumnInterpreter()

Method Summary

BigDecimal	add(BigDecimal bd1, BigDecimal bd2)
BigDecimal	castToCellType(BigDecimal bd)
BigDecimal	castToReturnType(BigDecimal bd)
int	compare(BigDecimal bd1, BigDecimal bd2)
double	divideForAvg(BigDecimal bd1, Long l2)
BigDecimal	getCellValueFromProto(HBaseProtos.BigDecimalMsg q)
BigDecimal	getMaxValue()
BigDecimal	getMinValue()
BigDecimal	getPromotedValueFromProto(HBaseProtos.BigDecimalMsg r)
HBaseProtos.BigDecimalMsg	getProtoForCellType(BigDecimal t)
HBaseProtos.BigDecimalMsg	getProtoForPromotedType(BigDecimal s)
HBaseProtos.EmptyMsg	getRequestData()
BigDecimal	getValue(byte[] colFamily, byte[] colQualifier, KeyValue kv)
BigDecimal	increment(BigDecimal bd)
void	initialize(HBaseProtos.EmptyMsg msg)
BigDecimal	multiply(BigDecimal bd1, BigDecimal bd2)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BigDecimalColumnInterpreter

public BigDecimalColumnInterpreter()

Method Detail

getValue

public BigDecimal getValue(byte[] colFamily,
                           byte[] colQualifier,
                           KeyValue kv)
                    throws IOException

Specified by:

getValue in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

Throws:

IOException

add

public BigDecimal add(BigDecimal bd1,
                      BigDecimal bd2)

Specified by:

add in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

compare

public int compare(BigDecimal bd1,
                   BigDecimal bd2)

Specified by:

compare in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getMaxValue

public BigDecimal getMaxValue()

Specified by:

getMaxValue in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

increment

public BigDecimal increment(BigDecimal bd)

Specified by:

increment in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

multiply

public BigDecimal multiply(BigDecimal bd1,
                           BigDecimal bd2)

Specified by:

multiply in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getMinValue

public BigDecimal getMinValue()

Specified by:

getMinValue in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

divideForAvg

public double divideForAvg(BigDecimal bd1,
                           Long l2)

Specified by:

divideForAvg in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

castToReturnType

public BigDecimal castToReturnType(BigDecimal bd)

Specified by:

castToReturnType in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

castToCellType

public BigDecimal castToCellType(BigDecimal bd)

Specified by:

castToCellType in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getRequestData

public HBaseProtos.EmptyMsg getRequestData()

Specified by:

getRequestData in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

initialize

public void initialize(HBaseProtos.EmptyMsg msg)

Specified by:

initialize in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getProtoForCellType

public HBaseProtos.BigDecimalMsg getProtoForCellType(BigDecimal t)

Specified by:

getProtoForCellType in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getProtoForPromotedType

public HBaseProtos.BigDecimalMsg getProtoForPromotedType(BigDecimal s)

Specified by:

getProtoForPromotedType in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getPromotedValueFromProto

public BigDecimal getPromotedValueFromProto(HBaseProtos.BigDecimalMsg r)

Specified by:

getPromotedValueFromProto in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>

getCellValueFromProto

public BigDecimal getCellValueFromProto(HBaseProtos.BigDecimalMsg q)

Specified by:

getCellValueFromProto in class ColumnInterpreter<BigDecimal,BigDecimal,HBaseProtos.EmptyMsg,HBaseProtos.BigDecimalMsg,HBaseProtos.BigDecimalMsg>