как зарегистрировать класс graphx Edge в Kryo? - PullRequest
0 голосов
/ 05 августа 2020

Я пытался зарегистрировать класс Edge в Kryo, но всегда получаю следующую ошибку.

java.lang.IllegalArgumentException: Class is not registered: org.apache.spark.graphx.Edge\nNote: To register this class use: kryo.register(org.apache.spark.graphx.Edge.class);

что не так со следующей строкой?

sc.getConf.registerKryoClasses(Array(Class.forName("org.apache.spark.graphx.Edge")))

Как я должен это сделать?

...