在zeppelin 0.8+spark中读取csv文件

yshpjwxd  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(547)

我正在尝试使用spark读取齐柏林飞艇便笺中的csv文件,如下所示(我还尝试了使用\或//的路径的多个语法):
这是我的密码:

  1. %spark
  2. val button2 = <div class="btn btn-success btn-sm">READ CSV</div>.onClick{() =>
  3. try {
  4. //val df = spark.read.option("header", "true").csv("C://Users/ut00xzh7/Documents/TEST_CSV_AC_CREATION/ac_lst.csv")
  5. val df = spark.read.format("com.databricks.spark.csv").option("header", "true").load("C://Users/ut00xzh7/Documents/TEST_CSV_AC_CREATION/ac_lst.csv")
  6. val res= df.collectAsList()
  7. AngularModel("result", res)
  8. }

我得到一个错误: java.io.IOException: No FileSystem for scheme: C 在做了一些研究之后,我发现我可以用 %dep 但我没有权利这么做,所以我在这个问题上有点结巴。

3npbholx

3npbholx1#

您需要将路径指定为 file:///C:/Users/... ,强制uri中的本地文件方案。否则磁盘 C 被视为uri的一个方案( scheme:authority/path

相关问题