HiveUdfRank的示例分析
小编给大家分享一下Hive Udf Rank的示例分析,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!
创新互联是一家专注网站建设、网络营销策划、微信小程序、电子商务建设、网络推广、移动互联开发、研究、服务为一体的技术型公司。公司成立十余年以来,已经为上千多家成都户外休闲椅各业的企业公司提供互联网服务。现在,服务的上千多家客户与我们一路同行,见证我们的成长;未来,我们一起分享成功的喜悦。
public final class Rank extends UDF { private int counter; private String last_dp_id; private String last_tid; //多参数 public int evaluate(String dp_id, String tid) { if (dp_id.equalsIgnoreCase(this.last_dp_id) && tid.equalsIgnoreCase(this.last_tid)) { this.counter++; }else{ this.counter = 0; this.last_dp_id = dp_id; this.last_tid = tid; } return this.counter; } //一个参数 public int evaluate(final String tid) { if (!tid.equals(this.last_tid)) { this.counter = 0; this.last_tid = tid; } return this.counter++; } }
看完了这篇文章,相信你对“Hive Udf Rank的示例分析”有了一定的了解,如果想了解更多相关知识,欢迎关注创新互联行业资讯频道,感谢各位的阅读!
名称栏目:HiveUdfRank的示例分析
标题链接:http://lswzjz.com/article/ijgisj.html