EuclidSimilarity.java 文件源码

@Override
public FloatWritable evaluate(DeferredObject[] arguments) throws HiveException {
    List<String> ftvec1 = HiveUtils.asStringList(arguments[0], arg0ListOI);
    List<String> ftvec2 = HiveUtils.asStringList(arguments[1], arg1ListOI);
    float d = (float) EuclidDistanceUDF.euclidDistance(ftvec1, ftvec2);
    float sim = 1.0f / (1.0f + d);
    return new FloatWritable(sim);
}