spark-cassandra-connector

1Hitze

1Antwort

Spark-SQL - registriert temporäre Tabelle nicht

finde ich den folgenden Befehl: spark-shell --packages datastax:spark-cassandra-connector:1.6.0-s_2.10 Dann hör ich den Zusammenhang mit: sc.stop Dann laufe ich diesen Code in der REPL: val conf =

0Hitze

1Antwort

Wie kann man entscheiden, ob die Leistung der Spark-Anwendung nahe am Maximum liegt (für gegebene Kerne und Speicher)?

Wir verwenden Cassandra 3.5 mit Spark 1.6.1 in 2-Knoten-Cluster (8 Kerne und 16 G Speicher pro Knoten). Es gibt die folgende Cassandra Tabelle CREATE TABLE schema.trade ( symbol text, date int, trad

0Hitze

2Antwort

sql Abfrage zu Spark-Cassandra-Cluster Sparsamkeitsserver gibt nicht

Ich habe eine Spark-Cassandra-Cluster eingerichtet. Cqlsh funktioniert gut. Ich habe den Thrift-Server gestartet und benutze die Beeline-Befehlszeile, um eine Verbindung herzustellen. Ich kann use sch

1Hitze

1Antwort

Funken Cassandra Steckverbinder - where-Klausel

Ich versuche, ein select where mit Datasax Cassandra Connector zu tun, aber ich bin immer folgende Fehlermeldung: java.io.IOException: Exception during preparation of SELECT "path" FROM "tracking"."us

2Hitze

1Antwort

Speichern von Daten von Spark zu Cassandra Ergebnisse in java.lang.ClassCastException

Ich versuche, Daten von Spark zu Cassandra in Scala mit saveToCassandra für eine RDD oder speichern mit einem Datenrahmen (beide in demselben Fehler) zu speichern. Die vollständige Nachricht ist: java

1Hitze

2Antwort

Kann Cassandra auf Docker mit Spark nicht laufen

Ich habe ein Zeppelin-Notebook auf Docker laufen. Ich habe den folgenden Code Cassandra mit: import org.apache.spark.sql.cassandra._ val cqlContext = new CassandraSQLContext(sc) cqlContext.sql("se

0Hitze

1Antwort

Scala: Speichern Ergebnis in einer ToDf-Tabelle

Ich versuche, einige Analysen in ToDF TempTable zu speichern, aber eine die folgenden Fehler erhalten ": 215: Fehler: Wert toDF ist kein Mitglied von Double". Ich lese Daten einer Cassandra-Tabelle, u

0Hitze

1Antwort

Wie speichere ich Daten aus Spark-Streaming in Cassandra mit Java?

Ich bekomme einige Einträge aus dem Stream in Linux-Terminal, weisen sie als lines, brechen sie in words. Aber anstatt sie auszudrucken, möchte ich sie in Cassandra speichern. Ich habe einen Keyspace

7Hitze

1Antwort

saveToCassandra mit Funken cassandra Stecker wirft java.lang.ClassCastException

Beim Versuch, Daten zu Cassandra (in Scala) zu speichern, erhalte ich die folgende Ausnahme: java.lang.ClassCastException: com.datastax. driver.core.DefaultResultSetFuture kann nicht auf com.google.co

0Hitze

1Antwort

Wie können wir mein bestehendes Projekt kafka - spark - cassandra auf kafka - dataproc - cassandra in google-cloud-platform bereitstellen?

Mein bestehendes Projekt ist Kafka-Spark-Cassandra. Jetzt habe ich GCP-Konto und muss Spark-Jobs zu Dataproc migrieren. In meinen bestehenden Spark-Jobs werden Parameter wie Masterip, Speicher, Kerne