JUST支持所有Flink1.10版本支持的UDF,具体内容点击此处查看。同时,JUST新增UDF如下:
UDF |
入参说明 |
返回值 |
说明 |
Timestamp st_utc2local(Timestamp value) |
value:UTC时间 |
Local时间 |
将UTC时间转成Local时间 |
Long st_timestamp2MS(Timestamp value) |
value:Timestamp |
13位毫秒值 |
将Timestamp转成毫秒值 |
String st_dateFormat(String value, String inputPattern[, String
outputPattern]) |
value:字符串类型的日期 inputPattern:输入的时间格式 outputPattern:输出的时间格式(可选,默认yyyy-MM-dd) |
指定格式的时间 |
将字符串类型的日期格式化成指定格式 |
String st_dateTimeFormat(String value, String inputPattern[, String
outputPattern]) |
value:字符串类型的时间 inputPattern:输入的时间格式 outputPattern:输出的时间格式(可选,默认yyyy-MM-dd HH:mm:ss) |
指定格式的时间 |
将字符串类型的时间格式化成指定格式 |
String st_dateTime2Timestamp(String value, String inputPattern) |
value:字符串类型的时间 inputPattern:输入的时间格式 |
Timestamp |
将字符串类型的时间转成Timestamp类型的时间 |
Point st_makePoint(Double lng, Double lat) |
lng:经度,lat:纬度 |
Point对象 |
将经纬度转成Point |
LineString st_makeLine(Row[] pointRows) |
pointRows:Point集合, Row<经度,纬度>格式的数组 |
LineString对象 |
将Point集合转成LineString |
Polygon st_makePolygon(LineString shell) |
shell:线 |
Polygon对象 |
将LineString转成Polygon |
Geometry st_makeBBOX(Double lowerX, Double lowerY, Double upperX,
Double upperY) |
lowerX:左下角的空间点经度,lowerY:左下角的空间点纬度,upperX:右上角的空间点经度,upperY:右上角的空间点纬度 |
Geometry对象 |
根据点坐标生成MBR |
Point st_pointFromText(String wkt) |
wkt:WKT字符串 |
Point对象 |
将WKT转成Point |
LineString st_lineFromText(String wkt) |
wkt:WKT字符串 |
LineString对象 |
将WKT转成LineString |
Polygon st_polygonFromText(String wkt) |
wkt:WKT字符串 |
Polygon对象 |
将WKT转成Polygon |
Geometry st_geomFromText(String wkt) |
wkt:WKT字符串 |
Geometry对象 |
将WKT转成Geometry |
Geometry st_geomFromWKT(String wkt) |
wkt:WKT字符串 |
Geometry对象 |
将WKT转成Geometry |
Geometry st_geomFromGeoHash(String hash, int prec) |
hash:GeoHash字符串,prec:位数 |
Geometry对象 |
将GeoHash转成Geometry |
Point st_pointFromGeoHash(String hash, int prec) |
hash:GeoHash字符串,prec:位数 |
Point对象 |
将GeoHash转成Point |
String st_asText(Geometry geom) |
geom:Geometry对象 |
WKT字符串 |
将Geometry转成WKT |
String st_geoHash(Geometry geom, int prec) |
geom:Geometry对象 ,prec:位数 |
GeoHash字符串 |
将Geometry转成GeoHash |
String st_asGeoJSON(Geometry geom) |
geom:Geometry对象 |
GeoJSON字符串 |
将Geometry转成GeoJSON |
Double st_x(Point point) |
point:Point对象 |
经度 |
从Point中获取经度 |
Double st_y(Point point) |
point:Point对象 |
纬度 |
从Point中获取纬度 |
Point st_castToPoint(Geometry geom) |
geom:Geometry对象 |
Point对象 |
将Geometry转成Point |
LineString st_castToLineString(Geometry geom) |
geom:Geometry对象 |
LineString对象 |
将Geometry转成LineString |
Polygon st_castToPolygon(Geometry geom) |
geom:Geometry对象 |
Polygon对象 |
将Geometry转成Polygon |
其他空间类型的UDF,具体内容点击此处查看。
注:本手册提供实时join维表&窗口统计示例,见附录4.4