Ich habe eine Tabelle Cassandra, dass der Einfachheit halber etwas wie folgt aussieht: key: text
jsonData: text
blobData: blob
ich einen Grunddatenrahmen für diese Verwendung Funken erzeugen kann
Ich habe ein Problem, wenn ich Funken lesen von Cassandra lesen. https://github.com/datastax/spark-cassandra-connector/blob/master/doc/8_streaming.md#reading-from-cassandra-from-the-streamingcontext D
habe ich das folgende Stück Code in Funken: rdd
.map(processFunction(_))
.saveToCassandra("keyspace", "tableName")
Wo def processFunction(src: String): Seq[Any] =
src match {
cas