spark-cassandra-connector

0Hitze

2Antwort

Funken Verbindung zu cassandra, scheitern op offene Verbindung

Das ist mein build.sbt name := "cassandra_test" version := "1.0" scalaVersion := "2.10.6" libraryDependencies ++= Seq("com.databricks" %% "spark-avro" % "2.0.1", "org.apache.spark" %% "spark-sq

0Hitze

1Antwort

Wie kann ich wissen, dass keine Zeilen mit Spark in Cassandra eingefügt werden

Ich füge in Cassandra mit Spark ein. CassandraJavaUtil.javaFunctions(newRDD) .writerBuilder("dmp", "dmp_user_user_profile_spark1", mapToRow(UserSetGet.class)).saveToCassandra(); logger.i

0Hitze

1Antwort

Cassandra auf einem einzigen physischen Knoten

Ich hatte gehofft, jemand könnte etwas konzeptionell klären, ich habe nach Antworten gesucht, aber diese Sache ist mir immer noch nicht ganz klar. Ich bin auf einem 16-Core-Rechner, der Zugriff auf ei

-1Hitze

1Antwort

Spark Cassandra Write Performance

Ich versuche rund 2 Millionen Datensätze in Cassandra durch Funken zu laden. Spark hat 4 Executoren und Cassandra hat 4 Knoten im Cluster. Aber es dauert ungefähr 20 Minuten, um alle Daten in Cassandr

0Hitze

1Antwort

Verwenden von SparkSQL, um zwei Tabellen auf Cassandra zu verbinden - FEHLER: fehlende EOF

Ich installierte Cassandra und Spark mit SparkSQL auf meinem Computer. Spark-SQL-Unterstützung Schlüsselwort JOIN https://docs.datastax.com/en/datastax_enterprise/4.6/datastax_enterprise/spark/sparkSq

0Hitze

1Antwort

Spark Cassandra Anwendung schlägt mit RECEIVED SIGNAL 15: SIGTERM

Ich bin eine Funken-Anwendung mit Funken-Cassandra-Connector ausgeführt. Die folgenden sind meine Funken einreichen Optionen --Klasse com.mobi.vserv.driver.Query5kPids1 --num-Testamentsvollstrecker 4

0Hitze

1Antwort

Ist es möglich, alle Zeilen der Cassandra-Partition in einem Spark-Worker zu lesen?

Ich versuche Zipkin Dependencies Spark job zu optimieren, um in weniger Stufen zu laufen, indem ich die Anzahl der reduceByKey Schritte minimiere, die es tut. Die Daten werden aus der folgenden Tabell

0Hitze

1Antwort

Funken- und cassandra, Bereichsabfrage auf Gruppierungsschlüssel

Ich haben cassandra Tabelle mit folgenden Struktur: CREATE TABLE-Tabelle ( Schlüssel int, Zeit Zeitstempel, Maß float, Primärschlüssel (Schlüssel, Zeit) ); Ich brauche einen Funkenjob zu erstellen, di

1Hitze

1Antwort

Cassandra schreiben gibt sehr langsam perfomance mit Funken

ich mit um mehr als 500 Millionen Platten eine cassandra Tabelle habe (In 6 Knoten), jetzt versuche ich zum Einfügen von Daten unter Verwendung von Funken cassandra-Stecker in Amazon EMR Tabelle Struk

0Hitze

1Antwort

[Cassandra] Filter auf Zeilenschlüsselebene in Cassandra sql in Spark-Job verursacht die Überkapazität der CPU-Auslastung

In meinem Spark-Job lese ich Daten aus Cassandra mit Java Cassandra util. Meine Abfrage liest sich wie- JavaRDD<CassandraRow> cassandraRDD = functions.cassandraTable("keyspace","column_family"). sele