一次Spark程序運行緩慢緣由排查

功能：判斷車輛軌跡數據在指定區域內停留時間超過半小時。java 實現思路：車輛定位數據生成RDD，遍歷RDD每一個元素，判斷是否在指定區域內，若是在，則累加計算停留時間，最後判斷停留時間是否超過半小時。併發 代碼：ide sortLocationInfoRDD.foreachPartition( new VoidFunction<Iterator<CarLo

>>阅读原文<<