|
@@ -25,7 +25,7 @@ public class XGBoostTrain {
|
|
|
.getOrCreate();
|
|
|
|
|
|
JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext());
|
|
|
- String file = "hdfs://dw/recommend/model/33_ad_train_data_v3_checkfeature/20240703/part-00099.gz";
|
|
|
+ String file = "/dw/recommend/model/33_ad_train_data_v3_checkfeature/20240703/part-00099.gz";
|
|
|
JavaRDD<String> rdd = jsc.textFile(file);
|
|
|
|
|
|
// 将 RDD[LabeledPoint] 转换为 JavaRDD<Row>
|