in lambda-kafka-function/src/main/java/com/amazonaws/hbase/lambda/RecordValidator.java [18:36]
public float getScore(HBaseCell column) throws InvalidInAppRecordException {
validateRecord(column);
if (new String(column.getQualifier()).toLowerCase().compareTo("speed")==0) {
float speed = Float.parseFloat(new String(column.getValue()));
if (speed >= 40 && speed <= 120) {
return (1-(Math.abs(speed - 80)/80)) * 100;
} else {
if (speed > 120) {
return 0;
} else {
return 0;
}
}
} else {
// we should never be here !
throw new InvalidInAppRecordException("not a speed record.");
}
}