spark-shell --packages com.springml:spark-sftp_2.11:1.1.3
import org.apache.commons.net.ftp.FTPClient
import org.apache.commons.net.ftp.FTPReply
import org.apache.commons.net.ftp.FTPSClient
import com.jcraft.jsch._
val jsch = new JSch()
var session = jsch.getSession("test","securetransfertest.com",22)
session.setPassword("test123")
var config = new java.util.Properties()
config.put("StrictHostKeyChecking", "no")
session.setConfig(config)
session.connect()
var channel = session.openChannel("sftp").asInstanceOf[ChannelSftp]
channel.connect()
println("Directory:" + channel.pwd()) // This prints the present working directory
session.disconnect()
//jsch.addIdentity(privatekeyfile);
Further research need to be done to put/get files from sftp server.
No comments:
Post a Comment