我是spark和cassandra的初学者。我正在研究一个场景,在这个场景中,我必须将sparkDataframe持久化到cassandra表中,而不给出表定义。。有可能吗?由于我的表标题不断变化,我使用datastax cassandra驱动程序。
zbwhf8kr1#
有可能保存一个 RDD 以及让连接器根据 RDD 项目类。保存 RDD 转到新表,而不是调用 saveToCassandra ,呼叫 saveAsCassandraTable 或者 saveAsCassandraTableEx 使用要创建的表的名称。这来自datastax spark cassandra连接器的文档。你可以在那里找到更多的细节。
RDD
saveToCassandra
saveAsCassandraTable
saveAsCassandraTableEx
1条答案
按热度按时间zbwhf8kr1#
有可能保存一个
RDD
以及让连接器根据RDD
项目类。保存
RDD
转到新表,而不是调用saveToCassandra
,呼叫saveAsCassandraTable
或者saveAsCassandraTableEx
使用要创建的表的名称。这来自datastax spark cassandra连接器的文档。你可以在那里找到更多的细节。