1
Я пытаюсь вставить в cassandra dataframe.Spark 1.6 вставка данных в Cassandra
Когда я пишу rdd.tosaveToCasssandra («пространство ключей», «стол»)
не проблема, но я не могу писать с этой функцией
myDataFrame.tosaveToCassandra("keyspace","table")
Также я пытался, но не спасло ,
myDataFrame.write.format("org.apache.spark.sql.cassandra").mode('append').options(table="mytable", keyspace="mykeyspace").save()
У вас есть какие-либо идеи, кроме как от нового API для Спарка 2,0
Благодарности
Произошла первая попытка. То есть только для RDDS, Второй подход правильный. Почему, по-вашему, это не спасло? – RussS
Я не думаю, что вы правильно дали варианты. Он ожидает карту, вы можете попробовать этот способ paddedGtpProfiles.write.format («org.apache.spark.sql.cassandra»). Mode (SaveMode.Append) .option («table», «mytable»). Option ("keyspace", "mykeyspace"). save() – Srini
У вас возникли какие-либо ошибки. – Srini