I would recommend the training exercises by data Artisans [1]. They have
challenging exercises and also nice solutions in Java and Scala.
Flink's end-to-end test also contain a lot of good example code [2].
I hope this helps.
Regards,
Timo
[1] http://training.data-artisans.com/
[2] https://gi
Hi Steve,
if you are ok with using the DataStream API you can simply use a map()
function [1] and call row.toString(). However, usually people want
custom logic to construct a string. This logic could either be in SQL
using the concat operator `||` or in the DataStream API.
Regards,
Timo
[1
I have created a project to use SQL but instead of printing the output as
below I need the output in a STRING so I can write it to a dynamoDB table.
How do I convert this "result" to a STRING or is there a suggestion of some
other way I should sink to dynamoDB? Any example code would REALLY help.