spark.sql("LOAD DATA LOCAL INPATH 'examples/src/main/resources/kv1.txt' INTO TABLE src");spark.sql("LOAD DATA LOCAL INPATH 'hdfs:///tmp/kv1.txt' INTO TABLE src");
最后一步是在original-s
我在远程服务器中的hdfs上有一个csv文件。我想使用安全的方法将csv文件读入熊猫的数据中,但是我一直收到一个错误。第一次尝试:代码:client_hdfs = InsecureClient('hdfs://host:port', user=user)with client_hdfs.read('path/to/csv.csv') as re