scala代码,用于自动创建cassandra表而不给出表定义

i34xakig  于 2021-06-15  发布在  Cassandra
关注(0)|答案(1)|浏览(313)

我是spark和cassandra的初学者。我正在研究一个场景,在这个场景中,我必须将sparkDataframe持久化到cassandra表中,而不给出表定义。。有可能吗?由于我的表标题不断变化,我使用datastax cassandra驱动程序。

zbwhf8kr

zbwhf8kr1#

有可能保存一个 RDD 以及让连接器根据 RDD 项目类。
保存 RDD 转到新表,而不是调用 saveToCassandra ,呼叫 saveAsCassandraTable 或者 saveAsCassandraTableEx 使用要创建的表的名称。
这来自datastax spark cassandra连接器的文档。你可以在那里找到更多的细节。

相关问题