Scala代码自动创建cassandra表而不给出表定义

Question

我是 spark 和 cassandra 的初学者。在我必须将 spark 数据帧保存到 cassandra 表中的情况下工作，而不给出表定义。这可能吗？由于我的表头不断变化 我正在使用 datastax cassandra 驱动程序。

Answer 1

可以将RDD 保存到现有的Cassandra 表中，也可以让连接器根据RDD 项目类的定义自动创建适当的表。

要将RDD 保存到新表中，而不是调用saveToCassandra，请使用您要创建的表的名称调用saveAsCassandraTable 或saveAsCassandraTableEx。

这是来自 Datastax Spark Cassandra 连接器的 documentation。您可以在那里找到更多详细信息。