资源介绍
spark 读取sftp文件
下面是用法
// Construct Spark dataframe using file in FTP server
DataFrame df = spark.read().
format("com.springml.spark.sftp").
option("host", "SFTP_HOST").
option("username", "SFTP_USER").
option("password", "****").
option("fileType", "json").
load("/ftp/files/sample.json")
// Write dataframe as CSV file to FTP server
df.write().
format("com.springml.spark.sftp").
option("host", "SFTP_HOST").
option("username", "SFTP_USER").
option("password", "****").
option("fileType", "json").
save("/ftp/files/sample.json");
- 上一篇: shell 编程(中文)[pdf]
- 下一篇:没有了