spark sftp

时间:2021-07-10 10:41:04
【文件属性】:

文件名称:spark sftp

文件大小:37KB

文件格式:JAR

更新时间:2021-07-10 10:41:04

spark sftp

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");


网友评论