spark-cassandra-connector

1Hitze

2Antwort

Per https://github.com/datastax/spark-cassandra-connector http://spark-packages.org/package/datastax/spark-cassandra-connector ich den Befehl tat, aber am Ende ist es wie es aussieht Fehler sind. S

0Hitze

1Antwort

Update eine Spalte in cassandra Tabelle

Ich habe eine cassandra Tabelle person_master (PersonId: int, customerId: Int, vorName: String, nachName: String, mrids: Set) primaryKey (PersonId und customerID) Angenommen, ich habe eine Eingabe-RDD

0Hitze

1Antwort

Update-Spalte des Settyps in Cassandra Zeile

Ich habe einen RDD [PersonType] = [PID, CID, Vorname, Nachname, Alter, Quelle, sourceType, Nachricht] Wert als RDD = [1000,100, Vikash, Singh, 33 , Quelle, sourceType, Nachricht] und ich habe csaandra

0Hitze

1Antwort

Datastax Verbindung Ausnahme bei Beeline oder Hive2 JDBC Treiber (Tableau)

Ich habe Datastax Enterprise 2.8 auf meinem dev VM (Centos 7) installiert. Die Installation lief reibungslos und der Single-Node-Cluster funktioniert gut. Aber wenn ich versuche, eine Verbindung zum C

1Hitze

2Antwort

Wie wird die Nummer der Partition beim Lesen von Daten aus Cassandra gesteuert?

I verwenden: cassandra 2.1.12 - 3 Knoten spark 1,6-3 Knoten spark cassandra Stecker 1,6 I verwenden Token in Cassandra (nicht vnodes). Ich schreibe einen einfachen Job zum Lesen von Daten aus einer Ca

0Hitze

1Antwort

Spark-Cassandra-Stecker Daten lesen

Ich habe Cluster von Cassandra-Knoten mit Spark Worker auf jedem Knoten Maschine. Für die Kommunikation verwende ich den Datastax Spark-Cassasndra Connector. Hat der Datastax-Konnektor eine Optimierun

2Hitze

1Antwort

leider nicht möglich, Cassandra 3.0 mit Funken cassandra Anschluss 1.5.0

Ausgabe verbinden - leider nicht möglich, Cassandra 3.0 verbinden mit Funken Cassandra Anschluss 1.5.0 Hintergrund - Ich habe versucht, Cassandra 3.0 eine Verbindung mit Spark 1.5. 0 unter Verwendung

6Hitze

1Antwort

Wie können Metriken wie Ausgabegröße und Datensätze, die von Spark UI geschrieben wurden, abgerufen werden?

Wie sammle ich diese Metriken auf einer Konsole (Spark Shell oder Spark-Übergabeprojekt) direkt nach der Aufgabe oder dem Job. Wir verwenden Spark, um Daten von Mysql zu Cassandra zu laden, und es ist

0Hitze

1Antwort

session.execute() nicht auf Cassandra, wenn auf Spark-Cluster

getan Ich bin ein Funke-Job, wo einige Daten aus Cassandra-Tabelle geladen ausgeführt. Aus diesen Daten mache ich einige Insert- und Delete-Anweisungen. und führen Sie sie aus. (mit forEach) boolean d

0Hitze

1Antwort

NoSuchMethod Ausnahme beim Lesen von Kassandra-Tabellen aus Pyspark

Ich versuche, Daten aus Cassandra-Schlüssel in Pyspark zu lesen. Hier ist mein Code: from pyspark import SparkContext from pyspark import SparkConf from pyspark.sql import SQLContext conf = Sp