-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathhive_spatial_udf
More file actions
96 lines (86 loc) · 7.9 KB
/
hive_spatial_udf
File metadata and controls
96 lines (86 loc) · 7.9 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
spark.sql("create temporary function ST_AsBinary as 'com.esri.hadoop.hive.ST_AsBinary'")
spark.sql("create temporary function ST_AsGeoJSON as 'com.esri.hadoop.hive.ST_AsGeoJson'")
spark.sql("create temporary function ST_AsJSON as 'com.esri.hadoop.hive.ST_AsJson'")
spark.sql("create temporary function ST_AsShape as 'com.esri.hadoop.hive.ST_AsShape'")
spark.sql("create temporary function ST_AsText as 'com.esri.hadoop.hive.ST_AsText'")
spark.sql("create temporary function ST_GeomFromJSON as 'com.esri.hadoop.hive.ST_GeomFromJson'")
spark.sql("create temporary function ST_GeomFromGeoJSON as 'com.esri.hadoop.hive.ST_GeomFromGeoJson'")
spark.sql("create temporary function ST_GeomFromShape as 'com.esri.hadoop.hive.ST_GeomFromShape'")
spark.sql("create temporary function ST_GeomFromText as 'com.esri.hadoop.hive.ST_GeomFromText'")
spark.sql("create temporary function ST_GeomFromWKB as 'com.esri.hadoop.hive.ST_GeomFromWKB'")
spark.sql("create temporary function ST_PointFromWKB as 'com.esri.hadoop.hive.ST_PointFromWKB'")
spark.sql("create temporary function ST_LineFromWKB as 'com.esri.hadoop.hive.ST_LineFromWKB'")
spark.sql("create temporary function ST_PolyFromWKB as 'com.esri.hadoop.hive.ST_PolyFromWKB'")
spark.sql("create temporary function ST_MPointFromWKB as 'com.esri.hadoop.hive.ST_MPointFromWKB'")
spark.sql("create temporary function ST_MLineFromWKB as 'com.esri.hadoop.hive.ST_MLineFromWKB'")
spark.sql("create temporary function ST_MPolyFromWKB as 'com.esri.hadoop.hive.ST_MPolyFromWKB'")
spark.sql("create temporary function ST_GeomCollection as 'com.esri.hadoop.hive.ST_GeomCollection'")
spark.sql("create temporary function ST_GeometryType as 'com.esri.hadoop.hive.ST_GeometryType'")
spark.sql("create temporary function ST_Point as 'com.esri.hadoop.hive.ST_Point'")
spark.sql("create temporary function ST_PointZ as 'com.esri.hadoop.hive.ST_PointZ'")
spark.sql("create temporary function ST_LineString as 'com.esri.hadoop.hive.ST_LineString'")
spark.sql("create temporary function ST_Polygon as 'com.esri.hadoop.hive.ST_Polygon'")
spark.sql("create temporary function ST_MultiPoint as 'com.esri.hadoop.hive.ST_MultiPoint'")
spark.sql("create temporary function ST_MultiLineString as 'com.esri.hadoop.hive.ST_MultiLineString'")
spark.sql("create temporary function ST_MultiPolygon as 'com.esri.hadoop.hive.ST_MultiPolygon'")
spark.sql("create temporary function ST_SetSRID as 'com.esri.hadoop.hive.ST_SetSRID'")
spark.sql("create temporary function ST_SRID as 'com.esri.hadoop.hive.ST_SRID'")
spark.sql("create temporary function ST_IsEmpty as 'com.esri.hadoop.hive.ST_IsEmpty'")
spark.sql("create temporary function ST_IsSimple as 'com.esri.hadoop.hive.ST_IsSimple'")
spark.sql("create temporary function ST_Dimension as 'com.esri.hadoop.hive.ST_Dimension'")
spark.sql("create temporary function ST_X as 'com.esri.hadoop.hive.ST_X'")
spark.sql("create temporary function ST_Y as 'com.esri.hadoop.hive.ST_Y'")
spark.sql("create temporary function ST_MinX as 'com.esri.hadoop.hive.ST_MinX'")
spark.sql("create temporary function ST_MaxX as 'com.esri.hadoop.hive.ST_MaxX'")
spark.sql("create temporary function ST_MinY as 'com.esri.hadoop.hive.ST_MinY'")
spark.sql("create temporary function ST_MaxY as 'com.esri.hadoop.hive.ST_MaxY'")
spark.sql("create temporary function ST_IsClosed as 'com.esri.hadoop.hive.ST_IsClosed'")
spark.sql("create temporary function ST_IsRing as 'com.esri.hadoop.hive.ST_IsRing'")
spark.sql("create temporary function ST_Length as 'com.esri.hadoop.hive.ST_Length'")
spark.sql("create temporary function ST_GeodesicLengthWGS84 as 'com.esri.hadoop.hive.ST_GeodesicLengthWGS84'")
spark.sql("create temporary function ST_Area as 'com.esri.hadoop.hive.ST_Area'")
spark.sql("create temporary function ST_Is3D as 'com.esri.hadoop.hive.ST_Is3D'")
spark.sql("create temporary function ST_Z as 'com.esri.hadoop.hive.ST_Z'")
spark.sql("create temporary function ST_MinZ as 'com.esri.hadoop.hive.ST_MinZ'")
spark.sql("create temporary function ST_MaxZ as 'com.esri.hadoop.hive.ST_MaxZ'")
spark.sql("create temporary function ST_IsMeasured as 'com.esri.hadoop.hive.ST_IsMeasured'")
spark.sql("create temporary function ST_M as 'com.esri.hadoop.hive.ST_M'")
spark.sql("create temporary function ST_MinM as 'com.esri.hadoop.hive.ST_MinM'")
spark.sql("create temporary function ST_MaxM as 'com.esri.hadoop.hive.ST_MaxM'")
spark.sql("create temporary function ST_CoordDim as 'com.esri.hadoop.hive.ST_CoordDim'")
spark.sql("create temporary function ST_NumPoints as 'com.esri.hadoop.hive.ST_NumPoints'")
spark.sql("create temporary function ST_PointN as 'com.esri.hadoop.hive.ST_PointN'")
spark.sql("create temporary function ST_StartPoint as 'com.esri.hadoop.hive.ST_StartPoint'")
spark.sql("create temporary function ST_EndPoint as 'com.esri.hadoop.hive.ST_EndPoint'")
spark.sql("create temporary function ST_ExteriorRing as 'com.esri.hadoop.hive.ST_ExteriorRing'")
spark.sql("create temporary function ST_NumInteriorRing as 'com.esri.hadoop.hive.ST_NumInteriorRing'")
spark.sql("create temporary function ST_InteriorRingN as 'com.esri.hadoop.hive.ST_InteriorRingN'")
spark.sql("create temporary function ST_NumGeometries as 'com.esri.hadoop.hive.ST_NumGeometries'")
spark.sql("create temporary function ST_GeometryN as 'com.esri.hadoop.hive.ST_GeometryN'")
spark.sql("create temporary function ST_Centroid as 'com.esri.hadoop.hive.ST_Centroid'")
spark.sql("create temporary function ST_Contains as 'com.esri.hadoop.hive.ST_Contains'")
spark.sql("create temporary function ST_Crosses as 'com.esri.hadoop.hive.ST_Crosses'")
spark.sql("create temporary function ST_Disjoint as 'com.esri.hadoop.hive.ST_Disjoint'")
spark.sql("create temporary function ST_EnvIntersects as 'com.esri.hadoop.hive.ST_EnvIntersects'")
spark.sql("create temporary function ST_Envelope as 'com.esri.hadoop.hive.ST_Envelope'")
spark.sql("create temporary function ST_Equals as 'com.esri.hadoop.hive.ST_Equals'")
spark.sql("create temporary function ST_Overlaps as 'com.esri.hadoop.hive.ST_Overlaps'")
spark.sql("create temporary function ST_Intersects as 'com.esri.hadoop.hive.ST_Intersects'")
spark.sql("create temporary function ST_Relate as 'com.esri.hadoop.hive.ST_Relate'")
spark.sql("create temporary function ST_Touches as 'com.esri.hadoop.hive.ST_Touches'")
spark.sql("create temporary function ST_Distance as 'com.esri.hadoop.hive.ST_Distance'")
spark.sql("create temporary function ST_Boundary as 'com.esri.hadoop.hive.ST_Boundary'")
spark.sql("create temporary function ST_Buffer as 'com.esri.hadoop.hive.ST_Buffer'")
spark.sql("create temporary function ST_ConvexHull as 'com.esri.hadoop.hive.ST_ConvexHull'")
spark.sql("create temporary function ST_Intersection as 'com.esri.hadoop.hive.ST_Intersection'")
spark.sql("create temporary function ST_Union as 'com.esri.hadoop.hive.ST_Union'")
spark.sql("create temporary function ST_Difference as 'com.esri.hadoop.hive.ST_Difference'")
spark.sql("create temporary function ST_SymmetricDiff as 'com.esri.hadoop.hive.ST_SymmetricDiff'")
spark.sql("create temporary function ST_SymDifference as 'com.esri.hadoop.hive.ST_SymmetricDiff'")
spark.sql("create temporary function ST_Aggr_ConvexHull as 'com.esri.hadoop.hive.ST_Aggr_ConvexHull'")
spark.sql("create temporary function ST_Aggr_Intersection as 'com.esri.hadoop.hive.ST_Aggr_Intersection'")
spark.sql("create temporary function ST_Aggr_Union as 'com.esri.hadoop.hive.ST_Aggr_Union'")
spark.sql("create temporary function ST_Bin as 'com.esri.hadoop.hive.ST_Bin'")
spark.sql("create temporary function ST_BinEnvelope as 'com.esri.hadoop.hive.ST_BinEnvelope'")
spark.sql("SELECT ST_AsText(new_geom) FROM gag LIMIT 1").collect().foreach(println)
spark.sql("SELECT ST_SRID(new_geom) FROM gag LIMIT 1").collect().foreach(println)