Re: MAP data type (PyFlink)

2022-01-30 Thread Francis Conroy
Hi Philippe, I don't think it's quite that simple unfortunately. A python dict can map from any hashable type to any value, however the 'equivalent' POJO, 'Map' in this case, requires all key types to be the same and all value types to be the same. You cannot specify multiple types for the key or

MAP data type (PyFlink)

2022-01-28 Thread Philippe Rigaux
Hello I want to send and receive dict Python values. According to the PyFlink doc, this is specified with Types.MAP(). Unfortunately I found no example of the required arguments, and I am stuck with the following error: TypeError: MAP() missing 2 required positional arguments: 'key_type_info'