Hi Dian,
Using .alias ended up working for me. Thanks for getting back to me.
On Thu, 17 Feb 2022 at 01:15, Dian Fu wrote:
> Hi Francis,
>
> There should be multiple ways to achieve this. Do you mean that all these
> methods don't work for you? If so, could you show the sample code? Besides,
>
Hi Francis,
There should be multiple ways to achieve this. Do you mean that all these
methods don't work for you? If so, could you show the sample code? Besides,
another way you may try is `inputmetrics.alias("timestamp, device, name,
value")`.
Regards,
Dian
On Wed, Feb 16, 2022 at 8:14 AM Franc
Hi all,
I'm hoping to be able to change the column names when creating a table from
a datastream, the flatmap function generating the stream is returning a
Tuple4.
It's currently working as follows:
inputmetrics = table_env.from_data_stream(ds, Schema.new_builder()
