1
A
回答
1
您可以使用DSE spark从Cluster1加载到Cluster2。 唯一的先决条件是在已加载数据的群集2中创建密钥空间和表。
对于下列设置:
源群集
群集1:
KEYSPACE:rrtest
表:rrexample
目标群集
群集2:
密钥空间:测试
表:例如
现在,这里所述第一步骤是创建keyspaces和表。 说出表具有以下说明(从CQL壳创建)
在簇1:
CREATE TABLE rrtest.rrexample
(
username text PRIMARY KEY,
password text,
state text
)
在簇2:
CREATE TABLE test.example
(
username text PRIMARY KEY,
password text,
state text
)
Scala代码迁移到Cluster2中
************ Load from Cluster 1*************
import com.datastax.spark.connector.cql._
import java.net.InetAddress
val myrdd = { implicit val src = CassandraConnector(Set(InetAddress.getByName("<ip : host1>"))); sc.cassandraTable("rrtest", "rrexample").select("username", "password", "state") }
************ Migrate to Cluster 2************
{ implicit val dst = CassandraConnector(Set(InetAddress.getByName("<ip:host2>"))); myrdd.saveToCassandra("test", "example") }
相关问题
- 1. 将cassanda数据从一个群集复制到另一个群集
- 2. apache spark集群
- 3. 在hadoop集群上安装spark集群
- 4. 将数据从一个CockroachDB集群复制到另一个
- 5. 卡桑德拉 - 从一个集群复制sstable快照到另一个集群
- 6. 如何验证DSE Spark Shell是否正在集群中分布
- 7. 如何将主题从kafka集群复制到另一个kafka集群?
- 8. 无法在Spark 1.4.1b群集上启动spark-shell群集
- 9. 将hive数据从一个Hadoop集群移到另一个集群而不使用distcp命令?
- 10. 在集群中加载库
- 11. 将K-means集群信息Apache Spark提取到JSON中
- 12. kmeans集群中的集群错误数
- 13. 从集群上的HDFS读取数据
- 14. 提取集群名称RegularExpressions
- 15. 如何将数据从边缘节点加载到Hadoop集群?
- 16. Mysql NDB集群设置后添加另一个数据节点
- 17. 使用spark与aws集群
- 18. 加入一个节点到集群
- 19. Crate IO数据库是否支持从一个集群备份并还原到不同的集群?
- 20. Spark:如何获取群集点(KMeans)
- 21. Spark 2.0 - 如何获取与群集中心关联的群集ID
- 22. 无法提交从Windows IDE到Linux集群的Spark作业
- 23. DBSCAN集群 - 当一个簇的边界点被认为是另一个集群
- 24. Jboss 6集群Singleton集群
- 25. 在独立群集中的spark中加载文件
- 26. 远程连接到Spark群集
- 27. Scala Spark连接到远程集群
- 28. 如何将数据从一个couchbase 2.5.1集群恢复到一个couchbase 3.0.3集群?
- 29. 谈到集群
- 30. Apache Spark独立群集调整参数