I’m afraid so, yes. I also tried out your example and it works if I add a
.returns() after the .map() (as you did). Somehow the TypeExtractor seems to be
acting up.
> On 02 Mar 2016, at 11:12, Simone Robutti wrote:
>
> >Error:(43, 87) java: no suitable method found for
> >returns(java.lang.Cl
Ok, I made it work but there's still an issue. I used
.returns(java.util.Map.class) after the "map" call and it works with this
simple function but it doesn't compile with my CustomMapFunction that
extends MapFunction. It gives a compilation error on the .returns() call.
This is the case only if t
I tried to simplify it to the bones but I'm actually defining a custom
MapFunction,java.util.Map> that
even with a simple identity function fails at runtime giving me the
following error:
>Exception in thread "main"
org.apache.flink.api.common.functions.InvalidTypesException: The return
type of fu
Hi,
what kind of program are you writing? I just wrote a quick example using the
DataStream API where I’m using Map> as the
output type of one of my MapFunctions.
Cheers,
Aljoscha
> On 01 Mar 2016, at 16:33, Simone Robutti wrote:
>
> Hello,
>
> to my knowledge is not possible to use a java.ut
Hello,
to my knowledge is not possible to use a java.util.Map for example in a
FlatMapFunction. Is that correct? It gives a
typer error at runtime and it doesn't work even with explicit
TypeInformation hints.
Is there any way to make it work?
Thanks,
Simone
