How can I pass an enum from mapper to reducer

Asked Mar 21 '18 at 17:20

Active Mar 21 '18 at 18:00

Viewed 81 times

I was trying to pass an enum from mapper to reducer, in job conf, I set
job.setMapOutputValueClass(StatisticTypes.class);
and in mapper, I passed a type of this enum, but always get

Type mismatch in value from map: expected StatisticTypes, recieved StatisticTypes$2

It seems like types of this enums were treated as a nested class of the enum
I'm wondering how can I set mapoutputvalueclass to include it's nested classes. Or is it possible to set multiple mapoutput classes?

Another related question
How to set mapOutputValueClass as Enum in hadoop

edited Mar 21 '18 at 18:00

asked Mar 21 '18 at 17:20

Han Yu

Have you looked at https://stackoverflow.com/a/23249886/729819 – Ben Watson Mar 22 '18 at 15:58
@BenWatson, I did look at that, the problem is not about how to implement writable interface for enums but the type mismatch between enum.class and types of enums.class – Han Yu Mar 22 '18 at 16:20

How can I pass an enum from mapper to reducer

0 Answers0