spark-cassandra-connector

2Hitze

1Antwort

Lesen und Schreiben an Cassandra von Spark worker wirft Fehler

Ich verwende den Datastax Cassandra Java-Treiber, um von Funkenarbeitern an Cassandra zu schreiben. Code-Snippet rdd.foreachPartition(record => { val cluster = SimpleApp.connect_cluster(Spark.ca

0Hitze

1Antwort

kann nicht gefunden werden Temp in Zeppelin

enter image description here Ich erhalte einen Fehler, wenn versuchen, über meine temporäre Tabelle auswählen. Jemand kann mir bitte helfen? object StreamingLinReg extends java.lang.Object{ val

0Hitze

1Antwort

Scala Funkendatenrahmen Gruppe mit Feld verschmelzenden

I haben Datenrahmen mit 5 Reihen: [user,sun,MainTest2,end,false] [user,sun,MainTest2,start,false] [user,sun,MainTest,end,true] [user,sun,MainTest,start,true] [user,sun,MainTest,start,true] Was i

0Hitze

1Antwort

Abfrage kann nicht basierend auf TimeUUID in Spark SQL

Ich versuche, die Cassandra-Datenbank mit SparkSQL-Terminal abzufragen. Abfrage: select * from keyspace.tablename where user_id = e3a119e0-8744-11e5-a557-e789fe3b4cc1; Error: java.lang.RuntimeExcep

0Hitze

1Antwort

Spark + Cassandra Integration

Ich habe eine Cassandra-3.7-Version und Spark-1.6.2-Version auf einer Hadoop-2.7.2-Version. Ich habe versucht, Cassandra mit Spark zu integrieren. Zu diesem Zweck folgen Sie den Anweisungen in http://

0Hitze

2Antwort

java Spark Streaming nach Cassandra

Ziel: Lesen Sie Kafka mit Spark-Streaming und speichern Sie Daten in Cassandra Von: Java Spark Cassandra-Anschluss 1.6 Dateneingabe: einfache JSON-Linie Objekt {"ID": "1", "field1": " Wert1} Ive eine

1Hitze

1Antwort

NoClassDefFoundError: org/apache/spark/sql/Datenrahmen in Spark-Cassandra-Connector

Ich versuche, spark-cassandra-connector von 1.4 auf 1.5 zu aktualisieren. Es steckte dann zwischen dem Prozess Alles scheint in Ordnung, aber wenn ich Testfälle laufen und melden Sie sich einige Fehle

1Hitze

1Antwort

Kopieren von Daten in Cassandra-Tabelle

Können wir mehrere Dateien in eine Acassandra-Tabelle importieren/kopieren, die denselben Spaltennamen in einer Tabelle und in Dateien haben? COPY tabelle1 (timestamp, temp, total_load, designl) VON '

0Hitze

1Antwort

Cassandra Spark Connector

Mein Cassandra CF hat Datum und ID als Partition Key. Während der Abfrage weiß ich nur das Datum, also ich Schleife über den Bereich der IDs. Meine Frage dreht sich darum, wie der Connector den folgen

3Hitze

1Antwort

So speichern Sie org.apache.spark.mllib.linalg.Vector im Datenframe zu Cassandra

Ich habe eine Anforderung zum Speichern von Datenrahmen, die org.apache.spark.mllib.linalg.Vector in einer der Spalte enthält. Beim Erstellen der Tabelle in Cassandra aus dem Datenframe wirft es Fehle