org.apache.flink.python.util

Class HashMapWrapper

java.lang.Object

org.apache.flink.python.util.HashMapWrapper

@Internal
public class HashMapWrapper
extends Object

Helper class to create a HashMap taking Numeric data as key or value from Python side. This is to avoid unexpected boxing/unboxing happens, see https://github.com/py4j/py4j/issues/374 for more details.

Constructor Summary

Constructors

Constructor and Description
HashMapWrapper(Class<?> keyCls, Class<?> valueCls)

Method Summary

Modifier and Type	Method and Description
HashMap	asMap()
void	put(Object key, Object value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HashMapWrapper

public HashMapWrapper(Class<?> keyCls,
                      Class<?> valueCls)

Method Detail

put

public void put(Object key,
                Object value)
         throws Exception

Throws:

Exception

asMap

public HashMap asMap()