spark-cassandra-connector

7Ciepło

2Odpowiedz

Datastax Cassandro sterownik wyrzucanie CodecNotFoundException

Dokładna Wyjątek jest następujący com.datastax.driver.core.exceptions.CodecNotFoundException: kodek nie znaleziono żądanej operacji: [-> varchar < java.math.BigDecimal] są to wersje oprogramowania uży

5Ciepło

2Odpowiedz

Wykonanie wkładki Cassandra przy użyciu złącza iskrobassandra

Jestem nowicjuszem do iskrzenia i kassandra. Próbuję wstawić do tabeli Cassandra za pomocą łącznika zapłonem Cassandra jak poniżej: import java.util.UUID import org.apache.spark.{SparkContext, Spark

9Ciepło

2Odpowiedz

scala.ScalaReflectionException: <none> nie jest terminem

Mam następujący fragment kodu w Spark: rdd .map(processFunction(_)) .saveToCassandra("keyspace", "tableName") Gdzie def processFunction(src: String): Seq[Any] = src match { case

6Ciepło

1Odpowiedz

Jak pobierać dane takie jak rozmiar wyjściowy i zapisy napisane w interfejsie użytkownika Spark?

W jaki sposób mogę zebrać te dane na konsoli (Spark Shell lub Spark submit job) zaraz po wykonaniu zadania lub zadania. Używamy Sparka do ładowania danych z Mysql do Cassandry i jest dość duży (np .:

10Ciepło

3Odpowiedz

Jak wysłać zapytanie do kolumny danych JSON za pomocą Spark DataFrames?

Mam tabeli Cassandra że dla uproszczenia wyglądał: key: text jsonData: text blobData: blob mogę utworzyć podstawowy ramkę danych dla tej użyciem iskry i Iskra-Cassandra złącza za pomocą: val df =

7Ciepło

2Odpowiedz

Czytanie z Cassandry za pomocą Spark Streaming

Mam problem, kiedy używam streamingu iskrowego do czytania z Cassandry. https://github.com/datastax/spark-cassandra-connector/blob/master/doc/8_streaming.md#reading-from-cassandra-from-the-streamingco

7Ciepło

1Odpowiedz

saveToCassandra ze złączem zapłonie Cassandra rzuca java.lang.ClassCastException

Gdy próbuje zapisać dane do Cassandry (w Scala), pojawia się następujący wyjątek: java.lang.ClassCastException: com.datastax. driver.core.DefaultResultSetFuture nie mogą być oddane do com.google.commo