spark-cassandra-connector

5ısı

1cevap

Cassandra Tabloya Veri Ekleme Spark DataFrame Kullanma

Scala Sürüm 2.10.5 Cassandra 3.0 ve Spark 1.6 kullanıyorum. Temel Örnek Works ve Cassandra.So içine mümkün eklemek bilgi Ben şemayı val person = sc.textFile("hdfs://localhost:9000/user/hduser/person")

scala apache-spark spark-cassandra-connector 2016-12-20

---

0ısı

1cevap

Bir Cassandra bölümünün Spark'da geniş bir sıra gibi hissettirmesi nasıl yapılır?

Cassandra, bölümlerini katlar halinde gösteriyor, ancak dahili olarak geniş satırlar halinde depolanıyor ve bu, Spark'le verdiğim veriler üzerinde çalışmak istediğim yoldur. Daha spesifik olmak gereki

apache-spark cassandra spark-cassandra-connector 2016-03-21

---

0ısı

1cevap

cassandra

Birinin kavramsal bir şeye açıklık getirmesini umuyordum, cevaplar için etrafa baktım ama bu şey hala bana tamamen açık değil. Cassandra .yaml yapılandırma dosyasında veri dizini olarak ayarlanmış/cas

apache-spark cassandra spark-cassandra-connector 2016-03-21

---

0ısı

1cevap

Yerel kıvılcım kıvılcım cassandra konektörü Spark kıvılcımı aşağı görünüyor

Kıvılcım ve cassandra için çok yeni. Ben datastax tarafından sağlanan kıvılcım-cassandra-bağlayıcı kullanarak cassandra tabloya yeni satırlar eklemek için çalışıyorum basit bir java progam çalışıyorum

apache-spark datastax datastax-enterprise spark-cassandra-connector 2016-03-26

---

1ısı

1cevap

Spark işinin kök nedenini Cassandra ile nasıl giderilir (ClassCastException - ShuffleMapTask to Task)?

Cassandra'dan Spark kullanarak veri okumaya çalışıyorum. DataFrame rdf = sqlContext.read().option("keyspace", "readypulse") .option("table", "ig_posts") .format("org.apache.spark.sql.cas

java apache-spark spark-cassandra-connector datastax-startup 2016-03-30

---