#java #apache-spark #dataframe #enums #rdd
#java #apache-spark #dataframe #перечисления #rdd
Вопрос:
Я пытаюсь преобразовать JavaRDD в Dataframe следующим образом:
JavaPairRDD<String, MyObject> myRdd = ...
DataFrame df = sqlContext.createDataFrame(myRdd.values(), MyObject.class)
Это работает нормально, пока у MyObject нет перечислений. Однако, если я добавляю поле перечисления, я получаю исключение нулевого указателя. В настоящее время мой обходной путь заключается в замене перечислений на строки, но мне было интересно, почему Dataframe не поддерживает перечисления.