Using RowTypeInfo with Table API

Posted by Jens Grassel on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Using-RowTypeInfo-with-Table-API-tp18588.html

Hi,

I tried to create a table from a DataStream[Row] but got a (somehow
expected) error:

<---snip--->
An input of GenericTypeInfo<Row> cannot be converted to Table. Please
specify the type of the input with a RowTypeInfo.
<---snip--->

Code looks like this:

val ds: DataStream[Row] = ...
val dT = streamTableEnvironment.fromDataStream(ds, 'f1, 'f2, ...)

However I have not found an example or hints at how to actually use the
mentioned RowTypeInfo to specify a column mapping for the table api.

Can anyone shed some light on this?

Regards,

Jens

--
CTO, Wegtam GmbH, 27. Hornung 2018, 14:28
Homepage : https://www.wegtam.com

So you think that money is the root of all evil.
Have you ever asked what is the root of money?
                -- Ayn Rand