我的新磚上使用“馬賽克”。重要的任務是創建一個熱圖的六邊形內H3決議。由於數據集很大我選擇馬賽克。作為第一步我試圖創建一個六邊形覆蓋特定區域但下麵的代碼並不生成六邊形覆蓋整個廣場如下圖所示:
從pyspark.sql。函數從鑲嵌進口進口* enable_mosaic enable_mosaic(火花,dbutils) pyspark從pyspark進口SparkContext。sql導入函數作為F進口馬賽克的mos馬賽克進口st_point朗= [-80。,-80年。,-70年。,-70年。,-80年。背闊肌= [35。,45。,45。,35歲。,35歲。]bounds_df =(火花.createDataFrame({“朗”:經度,“緯度”:lat}為經度,緯度在zip(經度,背闊肌)).coalesce (1) .withColumn (“point_geom st_point(“朗”、“緯度”)))bounds_df.show()從鑲嵌進口st_makeline bounds_df = (bounds_df .groupBy () .agg (F.collect_list .alias (“point_geom”) (“bounding_coords”)) .select (st_makeline .alias (“bounding_coords”) (“bounding_ring”))) bounds_df.show()從鑲嵌進口st_makepolygon bounds_df = bounds_df.select (st_makepolygon .alias (“bounding_ring”)(“範圍”))bounds_df.show()六角= (bounds_df .select(金屬氧化物半導體。mosaic_explode(“界限”,點燃(5))).select(“指數。*”))hexs.show () % % mosaic_kepler十六進製“index_id”“h3”
你知道為什麼有六邊形之間的差距嗎?
