From 4c79cad3224cfb5a613953926bbfe2d54991887f Mon Sep 17 00:00:00 2001 From: fly6516 Date: Wed, 16 Apr 2025 09:45:22 +0800 Subject: [PATCH] =?UTF-8?q?fix(data):=20=E6=9B=B4=E6=96=B0=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=96=87=E4=BB=B6=E8=B7=AF=E5=BE=84-=20=E5=B0=86=20Go?= =?UTF-8?q?ogleProducts.csv=20=E5=92=8C=20AmazonProducts.csv=20=E6=9B=BF?= =?UTF-8?q?=E6=8D=A2=E4=B8=BA=20Google.csv=20=E5=92=8C=20Amazon.csv=20-=20?= =?UTF-8?q?=E7=A1=AE=E4=BF=9D=E4=BB=A3=E7=A0=81=E8=83=BD=E5=A4=9F=E6=AD=A3?= =?UTF-8?q?=E7=A1=AE=E5=8A=A0=E8=BD=BD=E6=95=B0=E6=8D=AE=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 3-1.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/3-1.py b/3-1.py index 6424816..48a8157 100644 --- a/3-1.py +++ b/3-1.py @@ -42,8 +42,8 @@ if __name__ == "__main__": stopwords = load_stopwords(sc) # 加载数据 - google = sc.textFile("hdfs://master:9000/user/root/GoogleProducts.csv") - amazon = sc.textFile("hdfs://master:9000/user/root/AmazonProducts.csv") + google = sc.textFile("hdfs://master:9000/user/root/Google.csv") + amazon = sc.textFile("hdfs://master:9000/user/root/Amazon.csv") # 提取内容 google_rdd = google.map(lambda line: extract_info(line, "google")) \