Ich habe den folgenden Code in Spark:
%Vor%Wo
%Vor%Wo:
%Vor% saveToCassandra
erwartet eine Sammlung von Objekten und verwendet Seq[Any]
als Rückgabetyp, um sowohl Seq[A]
als auch Seq[B]
breaks saveToCassandra
mit Ausnahme zu enthalten - scala.ScalaReflectionException: <none>
ist kein Begriff. Was könnte der Grund für dieses Verhalten sein?
So etwas mag funktionieren. Ich habe jedoch nicht viel mit dem Speichern von Objekten in Cassandra herumgespielt. Ich benutze auch keine mit Cassandra. Die obige Lösung ohne die Fallklassen und Anys ist jedoch, wie ich kürzlich ein solches Problem gelöst habe. Zum Beispiel würde das Folgende funktionieren.
%Vor%Das ist jedoch nicht genau das, was Sie wollen. Also ja, nimm es für das, was du willst.
Tags und Links scala apache-spark spark-cassandra-connector