Is the class mentioned in the exception below the parent class of the
anonymous "Function" class you're creating?
If so, you may need to make it serializable. Or make your function a
proper "standalone" class (either a nested static class or a top-level
one).
On Wed, May 11, 2016 at 3:55 PM, Andy
I have a streaming app that receives very complicated JSON (twitter status).
I would like to work with it as a hash map. It would be very difficult to
define a pojo for this JSON. (I can not use twitter4j)
// map json string to map
JavaRDD> jsonMapRDD = powerTrackRDD.map(new
Function>(){
private
