Scala-код для автоматического создания таблицы Кассандры без определения таблицы - PullRequest
0 голосов
/ 26 сентября 2018

Я новичок в spark и cassandra. Я работаю над сценарием, в котором мне нужно сохранить искровые кадры данных в таблице cassandra, не давая определения таблиц ... возможно ли это?Поскольку мой заголовок таблицы постоянно меняется, я использую драйвер dasastax cassandra.

1 Ответ

0 голосов
/ 26 сентября 2018

Можно сохранить RDD в существующей таблице Cassandra, а также позволить соединителю автоматически создать соответствующую таблицу на основе определения класса элементов RDD.

Чтобы сохранить RDD в новой таблице, вместо вызова saveToCassandra, вызовите saveAsCassandraTable или saveAsCassandraTableEx с именем таблицы, которую вы хотите создать.

Это из документации Datastax Spark Cassandra Connector.Вы можете найти более подробную информацию там.

...