Map to Map в Spark ⇐ JAVA

[Anonymous]

Я получил исключение ниже в Java Spark, пытаясь кодировать pojo с полем типа карты < /p>

Код: Выделить всё

Caused by: org.codehaus.commons.compiler.CompileException: File 'generated.java', Line 622, Column 51: failed to compile: org.codehaus.commons.compiler.CompileException: File 'generated.java', Line 622, Column 51: A method named "toJavaBigDecimal" is not declared in any enclosing class nor any supertype, nor through a static import
< /code>
Итак, я написал ниже UDF, чтобы преобразовать карту  на карту  < /p>
UserDefinedFunction strMapToBigDecimalMap = udf((Map s) -> {
Map s1 = new HashMap();
for (String key : s.keySet()) {
s1.put(key, new BigDecimal(s.get(key)));
}
return s1;
}, new MapType());
< /code>
Но это возвращает приведенное ниже исключение. Как мне это решить? < /P>
 scala.MatchError: null

По сути, я ищу UDF, который будет конвертировать карту в карту

Подробнее здесь: https://stackoverflow.com/questions/794 ... l-in-spark