|
@@ -77,7 +77,7 @@ object makedata_15_bucket_20240608 {
|
|
if (!buffers.contains(data2.last)) {
|
|
if (!buffers.contains(data2.last)) {
|
|
buffers += data2.last
|
|
buffers += data2.last
|
|
}
|
|
}
|
|
- result.add(contentList(i) + "\t" + buffers.mkString(","))
|
|
|
|
|
|
+ result.add(contentList(i) + "\t" + bucketNum.toString + "\t" + buffers.mkString(","))
|
|
}
|
|
}
|
|
// }
|
|
// }
|
|
val data3 = sc.parallelize(result)
|
|
val data3 = sc.parallelize(result)
|