com.arangodb.velocypack.exception.VPackParserException: java.lang.InstantiationException

Question

ich versuche, meine ArangoDb-Datenbank mit scala zu verbinden, aber wenn die Verbindung hergestellt wird und ich die Operation mache, habe ich einen VPackParserException-Fehler. Mein Code:

import com.arangodb.spark.{ArangoSpark, ReadOptions} 
import org.apache.spark.SparkContext 
import org.apache.spark.SparkConf 
import scala.beans.BeanProperty 

object ArangotoSpark { 

def main(args: Array[String]) { 
    case class netflow(@BeanProperty SrcHost: String, 
        @BeanProperty DstHost: String, 
        @BeanProperty SrcPort: String, 
        @BeanProperty DstPort: String, 
        @BeanProperty Protocol: String, 
        @BeanProperty StartTS: String, 
        @BeanProperty EndTS: String, 
        @BeanProperty Packets: Int, 
        @BeanProperty Bytes: Int) { } 

    val conf = new SparkConf().setAppName("Simple Application").setMaster("local[*]") 
    .set("arangodb.host", "127.0.0.2") 
    .set("arangodb.port", "8529") 
    .set("arangodb.user", "root") 
    .set("arangodb.password", "rut") 
    .set("arangodb.database", "netflow") 
    val sc = new SparkContext(conf) 
    val rdd = ArangoSpark.load[netflow](sc, "N201701031130", ReadOptions("netflow")) 
    val rdd2 = rdd.filter { x => x.SrcHost.matches("15.33.165.30") } 
    rdd2.count() 
    } 
} 

Jede Hilfe wird geschätzt. Vielen Dank.

UPDATE: Jetzt sieht mein Code wie folgt aus:

case class nf (@BeanProperty cadena: String){ 
    def this() = this(cadena = null)} 
val rdd = ArangoSpark.load[nf](sc, "N201701031130", ReadOptions("netflow")) 
println(rdd.count()) 
println("*************************************") 
rdd.collect.foreach(println(_)) 

rdd.count die richtige Anzahl von Dokumenten gibt, aber wenn ich versuche, sie zu drucken, ich habe nur nf (null) Linien

Answer 1

Ihre Klasse netflow benötigt einen parameterlosen Konstruktor.

Der VelocyPack Deserializer, der eingehende VelocyPack in Java-/Scala-Objekte deserialisiert - unter der Haube des Java-Treibers - benötigt es, um Ihre Klasse zu instanziieren.

Update:

Sie müssen es nicht analysieren mit den Feldnamen zu arbeiten. Ihre Fallklasse kann dieselben Felder wie die gespeicherten Dokumente haben. Der Serializer/Deserializer aus dem Java-Treiber kann damit arbeiten. Sie benötigen aber auch einen parameterlosen Konstruktor.

Ihr Fall Klasse wie folgt aussehen könnte:

case class netflow(@BeanProperty SrcHost: String, 
        @BeanProperty DstHost: String, 
        @BeanProperty SrcPort: String, 
        @BeanProperty DstPort: String, 
        @BeanProperty Protocol: String, 
        @BeanProperty StartTS: String, 
        @BeanProperty EndTS: String, 
        @BeanProperty Packets: Int, 
        @BeanProperty Bytes: Int) { 
    def this() = this(null,null,null,null,null,null,null,null,null)} 
}