ZScoreUDF.java 文件源码

public FloatWritable evaluate(float value, float mean, float stddev) {
    if (stddev == 0.f) {
        return new FloatWritable(0.f);
    }
    float v = (value - mean) / stddev;
    return new FloatWritable(v);
}