При использовании Sqoop из командной строки я могу использовать Oracle Wallet, как описано в Блоге ASF , например:
export HADOOP_OPTS= "-Doracle.net.tns_admin=$PWD/wallet -Doracle.net.wallet_location=$PWD/wallet"
sqoop import -D mapred.map.child.java.opts= '-Doracle.net.tns_admin=. -Doracle.net.wallet_location=.'
-files $HOME/wallet/cwallet.sso,\
$HOME/wallet/ewallet.p12,\
$HOME/wallet/sqlnet.ora,\
$HOME/wallet/tnsnames.ora \
-connect ‘jdbc:oracle:thin:@w_orcl’ \
<<rest of sqoop options>>
Но как я могу использовать Oracle Wallet при использовании dev API Sqoop, когда делаю что-то вроде ...
import com.cloudera.sqoop.SqoopOptions()
import org.apache.sqoop.tool.ImportTool()
val options = new SqoopOptions()
// set the sqoop options here
val importTool = new ImportTool()
importTool.run(options)
... внутри задания Spark, предназначенного для программной автоматизации нескольких заданий Sqoop и запросов SparkSQL?