我正在使用spark将一些数据从一个cassandra表移动到另一个集群上的另一个cassandra表。
我为以下源集群之一指定了cassandra配置:
/*
spark.cassandra.connection.host:
spark.cassandra.connection.port:
spark.cassandra.auth.username:
spark.cassandra.auth.password:
spark.cassandra.connection.ssl.clientAuth.enabled: true
spark.cassandra.connection.ssl.enabled: true
spark.cassandra.connection.ssl.trustStore.path:
spark.cassandra.connection.ssl.trustStore.password:
spark.cassandra.connection.timeout_ms: */
SparkSession spark = SparkSession.builder()
.config(conf)
.getOrCreate();
Dataset<Row> df = spark.read()
.format("org.apache.spark.sql.cassandra")
.options(config.getsourcetable())
.load();
df.show();
// *** How/Where do I specify cassandra config in destination cluster? ***
df.write()
.mode(SaveMode.Append)
.format("org.apache.spark.sql.cassandra")
.options(destinationTbl);
如何/在哪里在目标集群(Java Perferred)中指定cassandra配置?
谢谢!