소스 검색

Update makedata_ad_32_bucket_20250110: fix type induction

StrayWarrior 3 달 전
부모
커밋
b645df4b0c
1개의 변경된 파일2개의 추가작업 그리고 1개의 파일을 삭제
  1. 2 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_32_bucket_20250110.scala

+ 2 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_32_bucket_20250110.scala

@@ -77,7 +77,8 @@ object makedata_ad_32_bucket_20250110 {
       } else {
         val headValue = iter.next()
         val key = headValue._1
-        val sortedValues = (Array(headValue._2) ++ iter.map(_._2).toArray).sorted
+        val leftValues = iter.map(_._2).toArray
+        val sortedValues = (Array(headValue._2) ++ leftValues).sorted
         val len = sortedValues.length
         val oneBucketNum = (len - 1) / (bucketNum - 1) + 1 // 确保每个桶至少有一个元素
         val buffers = new ArrayBuffer[Double]()