|
@@ -65,7 +65,7 @@ public class XGBoostTrain {
|
|
|
|
|
|
JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext());
|
|
|
String file = "/dw/recommend/model/33_ad_train_data_v4/20240726/part-00099.gz";
|
|
|
- file = "/Users/dingyunpeng/Desktop/part-00099.gz";
|
|
|
+ //file = "/Users/dingyunpeng/Desktop/part-00099.gz";
|
|
|
JavaRDD<String> rdd = jsc.textFile(file);
|
|
|
|
|
|
// 将 RDD[LabeledPoint] 转换为 JavaRDD<Row>
|