Hi,
I tried to remove the returns function but if I do it, the program returns
an error (curious since the return value is a Double).
I'm absolutely sure env.execute() is called because I see other streams
printed.
The program is connected, I followed exactly the example showed in the
library, I
Hi Andrea,
a MapFunction calls its map() function for each stream element and returns
exactly one result value.
MapFunctions are used for 1-to-1 transformations.
The returns() method allows to specify the return type of an operator, in
your case the MapOperator. It is only necessary if Flink canno
Hi,
Excuse me for the unclear title but I don't know how to summarise the
question.
I'm using an external library integrated with Flink called Flink-HTM. It is
still a prototype.
Internally, it performs everything I want but I have a problem returning
evaluated values in a printable datastream.
I
