Using scala.collection.immutable.Map inside my java class

Question

I get bellow exception from my java codes.

 java.lang.ClassCastException: scala.collection.immutable.Map$Map1 cannot be cast to java.util.HashMap
    at au.com.vroc.udf.medianUDF.update(medianUDF.java:79)

I am getting error in my spark application when I cast the buffer to HashMap of java.utill. This is my codes:

    public void update(MutableAggregationBuffer buffer, Row input) {
    if (!input.isNullAt(0)) {   

        HashMap currentBuffer=(HashMap) buffer.get(0);//getting exception here
        //HashMap currentBuffer=new HashMap();  
        currentBuffer.put(input.getLong(0), input.getDouble(0));

        //currentBuffer.add(currentMap);

        buffer.update(0, currentBuffer);

    }
}

I guess instead of java hashmap I have to use "scala.collection.immutable.Map$Map1" inside my java class. Can I use any tool in "JavaConversions" namespace.

Anyhep would be appreciated!

J0HN · Accepted Answer · 2018-01-03 15:09:48Z

2

Simplest approach would likely be to use Scala Converters.

It should look something like this (not tested, but type-checks):

import scala.collections.JavaConverters

java.util.Map currentBuffer = JavaConverters.mapAsJavaMapConverter(buffer.get(0)).asJava();

Please note that it returns type-parameterized map (i.e. java.util.Map<K, V>), not the non-parameterized java.util.HashMapin your example - you might want to alter the rest of your code to work on the parameterized maps for better type safety.

answered Jan 3, 2018 at 15:09

J0HN

27.1k5 gold badges59 silver badges88 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Alper t. Turker Over a year ago

Upvoted, but it is not necessary. There is getJavaMap method which applies conversions automatically.

Alper t. Turker · Accepted Answer · 2018-01-03 17:51:20Z

1

You get java.util.Map you should use getJavaMap method:

java.util.Map<T, U> currentBuffer = (java.util.Map<T, U>) first.getJavaMap(0)

Note that this is not HashMap - initialized value is Encoded on update and decoded on get. To modify it, you have to make a copy.

answered Jan 3, 2018 at 17:51

Alper t. Turker

35.3k9 gold badges89 silver badges118 bronze badges

Collectives™ on Stack Overflow

Using scala.collection.immutable.Map inside my java class

2 Answers 2

1 Comment

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Related