spark-cassandra-connector

6calore

1risposta

Come recuperare le metriche come la dimensione dell'output e i record scritti dall'interfaccia utente di Spark?

Come raccogliere queste metriche su una console (Spark Shell o Spark submit job) subito dopo l'esecuzione dell'attività o del lavoro. Usiamo Spark per caricare dati da Mysql a Cassandra ed è piuttosto

10calore

3risposta

Come interrogare la colonna di dati JSON usando Spark DataFrames?

Ho una tabella Cassandra che per semplicità simile a: key: text jsonData: text blobData: blob posso creare una cornice di dati di base per questo utilizzando scintilla e la scintilla-cassandra-con

7calore

3risposta

Versione guava durante l'utilizzo della shell di accensione

Sto provando a utilizzare il connettore spark-cassandra tramite spark-shell su dataproc, tuttavia non riesco a connettermi al mio cluster. Sembra che ci sia una mancata corrispondenza della versione p

7calore

2risposta

Lettura da Cassandra con Spark Streaming

Ho un problema quando utilizzo lo sparkming per leggere da Cassandra. https://github.com/datastax/spark-cassandra-connector/blob/master/doc/8_streaming.md#reading-from-cassandra-from-the-streamingcont

7calore

1risposta

saveToCassandra con connettore scintilla cassandra getta java.lang.ClassCastException

Quando si cerca di salvare i dati a Cassandra (in Scala), ottengo la seguente eccezione: java.lang.ClassCastException: com.datastax. driver.core.DefaultResultSetFuture non può essere lanciato a com.go

7calore

2risposta

Datastax Cassandra driver gettando CodecNotFoundException

L'eccezione esatto è il seguente com.datastax.driver.core.exceptions.CodecNotFoundException: Codec non trovato per il funzionamento richiesto: [varchar < -> java.math.BigDecimal] Queste sono le versio

9calore

2risposta

scala.ScalaReflectionException: <none> non è un termine

Ho il seguente pezzo di codice in Spark: rdd .map(processFunction(_)) .saveToCassandra("keyspace", "tableName") Dove def processFunction(src: String): Seq[Any] = src match { case