flink 注册函数示例
2024-10-20 17:27:38
需求 (filter):
现在有这么一个需求,统计出现在纽约的行车记录。这里我们需要进行一个过滤的操作,我们需要有个自定义的 UDF ,具体思路是,表里面有经度和维度这两个字段,通过这个可以来开发一个是否在纽约的 UDF。
public class IsInNYC extends ScalarFunction { // geo boundaries of the area of NYC
private static double LON_EAST = -73.7;
private static double LON_WEST = -74.05;
private static double LAT_NORTH = 41.0;
private static double LAT_SOUTH = 40.5; public static boolean eval(float lon, float lat) {
return isInNYC(lon, lat);
} public static boolean isInNYC(float lon, float lat) { return !(lon > LON_EAST || lon < LON_WEST) &&
!(lat > LAT_NORTH || lat < LAT_SOUTH);
}
}
最新文章
- Process的Waitfor() 引起代码死锁
- JqueryEasyUI 解决IE下加载时页面错乱的问题 分类: JavaScript JqueryEasyUI 2014-09-20 09:50 545人阅读 评论(1) 收藏
- P1010 幂次方
- HDU-- Buy Tickets
- LabVIEW设计模式系列——各种各样的状态机
- cocoaPods下载使用记录
- 关于百度 UEditor的使用
- 【转】AFNetworking之于https认证
- Winform TabControl控件使用
- AngularJs中,如何在父元素中调用子元素为自定义Directive中定义的函数?
- asp.net接收发送的xml字符串数据
- Windows系统字体与文件对照表
- 【Android Developers Training】 86. 基于连接类型修改您的下载模式
- hdu 5637 BestCoder Round #74 (div.2)
- ACM-ICPC 2018 焦作赛区网络预赛 I Save the Room(水题)
- Cocos Creator学习四:按钮响应事件
- Day 08 文件操作模式,文件复制,游标
- CodeChef KILLKTH Killjee and k-th letter
- hive sql 语句执行顺序及执行计划
- DDD-002