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]
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/#datastream-transformations
Am 13.11.18 um 07:46 schrieb Steve Beischlien:
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. THANKS!!
Table result = tableEnv.sql("SELECT 'Alert ',t_sKey, t_deviceID, t_sValue FROM SENSORS WHERE
t_sKey='TEMPERATURE' AND t_sValue > " + TEMPERATURE_THRESHOLD); tableEnv.toAppendStream(result, Row.class).print();
Any assistance would be very appreciated.
Thanks
