AngularDistanceUDF.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 = 1.f - AngularSimilarityUDF.angularSimilarity(ftvec1, ftvec2);
    return new FloatWritable(d);
}