java.lang.UnsupportedOperationException: 'Boş olmayan bir Cassandra Tablosuna yazma izin verilmiyor

Question

Akış programım tarafından işlenen akış verisini alacağım senaryo var ve her aralığın çıktılarıma ekleniyor. mevcut cassandra tablosu.

Şu anda bu kıvılcım akışı programım, cassandra masamda kaydetmem gereken bir veri çerçevesi oluşturacak. Ben şu anda karşı karşıyayım sorun i o mod = "Ekle" geçti nerede bağlantıyı http://rustyrazorblade.com/2015/08/migrating-from-mysql-to-cassandra-using-spark/ aşağıdaki okumuştu

dff.write.format("org.apache.spark.sql.cassandra").options(Map("table" -> "xxx", "yyy" -> "retail")).save() 

komuta altında kullandığınızda benim mevcut cassandra tabloya veri/satır eklenemez mümkün değilim olduğunu tasarruf yöntemine ama onun atma sözdizimi hatası Ayrıca

içine i benim kıvılcım yazma bu issue.I'm nasıl düzeltileceği olarak yardıma mı ihtiyacınız aşağıdaki linke https://groups.google.com/a/lists.datastax.com/forum/#!topic/spark-connector-user/rlGGWQF2wnM

dan düzeltmek gerekiyor nereye anlamak nt başardı scala

akışında iş akışı

Answer 1

Ben bunu şu şekilde yapmama düşünüyorum:

dff.write.format("org.apache.spark.sql.cassandra").mode(SaveMode.Append).options(Map("table" -> "xxx", "yyy" -> "retail")).save() 

cassandra veri güçleri sözde 'upserts' yapmak işleme şekli - Bir ekleme bazı satırları üzerine yazabilir hatırlamak zorunda Kayıtlı kaydın birincil anahtarı, eklenen kayıtların birincil anahtarı ile aynıdır. Cassandra 'hızlı' bir veritabanıdır, bu yüzden yazmadan önce veri varlığını kontrol etmez.