无用备注调整

eagleEye-flink_kafka/src/main/java/com/flink/achieve/doris/VectorAngleCalculationAchi.java

@@ -405,7 +405,7 @@ public class VectorAngleCalculationAchi extends MultipleSourceCommonBase impleme
 	}
 	}
 	
 	
 	private List<Point> getReferenceVector(String id) {
 	private List<Point> getReferenceVector(String id) {
-	    // 示例：根据ID生成线性路径
+	    //根据ID生成线性路径
 	    List<Point> refPoints = new ArrayList<>();
 	    List<Point> refPoints = new ArrayList<>();
 	    for (int i = 0; i < 5; i++) {
 	    for (int i = 0; i < 5; i++) {
 	        refPoints.add(new Point(i * 10, i * 10)); // 生成点(0,0),(10,10)...
 	        refPoints.add(new Point(i * 10, i * 10)); // 生成点(0,0),(10,10)...

eagleEye-flink_kafka/src/main/java/com/flink/processor/function/KeyPointSelector.java

@@ -72,7 +72,7 @@ public class KeyPointSelector extends KeyedProcessFunction<Tuple2<String, Long>,
         }
         }
         allPoints.sort(Comparator.comparingLong(p -> p.rowNum));
         allPoints.sort(Comparator.comparingLong(p -> p.rowNum));
         
         
-        // 2. 执行关键点选择算法（Python逻辑）
+        // 2. 执行关键点选择算法
         List<ResultRecord> keyPoints = selectKeyPoints(allPoints);
         List<ResultRecord> keyPoints = selectKeyPoints(allPoints);
         
         
         // 3. 生成坐标数组字符串
         // 3. 生成坐标数组字符串
@@ -117,7 +117,7 @@ public class KeyPointSelector extends KeyedProcessFunction<Tuple2<String, Long>,
             // 5. 计算角度（弧度转角度）
             // 5. 计算角度（弧度转角度）
             double angle = Math.abs(Math.atan2(dy, dx) * 180 / Math.PI);
             double angle = Math.abs(Math.atan2(dy, dx) * 180 / Math.PI);
             
             
-            // 6. 阈值检查（与Python逻辑一致）
+            // 6. 阈值检查
             if (distance > DISTANCE_THRESHOLD && angle > ANGLE_THRESHOLD) {
             if (distance > DISTANCE_THRESHOLD && angle > ANGLE_THRESHOLD) {
                 keyPoints.add(candidate);
                 keyPoints.add(candidate);
                 currentKeyPoint = candidate; // 更新当前关键点
                 currentKeyPoint = candidate; // 更新当前关键点