Я пытаюсь сохранить набор структурированных паровых данных в заданную таблицу Кассандры.
Я использую версию разъема dasastax cassandra spark-cassandra-connector_2-11.jar
Пока я пытаюсь сохранить данные, установите, как показано ниже
dataSet
.writeStream()
.format("org.apache.spark.sql.cassandra")
.option("table",columnFamilyName)
.option("keyspace", keyspace)
.outputMode("append")
.start();
Ошибка броска:
Источник данных org.apache.spark.sql.cassandra не поддерживает потоковую передачу
писать
Что нужно сделать и как с этим справиться?