Re: Using RowTypeInfo with Table API

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

Hi Jens,

you can always use TypeInformation.of() for all supported Flink types.
In [1] you can also find a list of all types.

Regards,
Timo

[1]
https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java


Am 2/27/18 um 3:13 PM schrieb Jens Grassel:

> Hi,
>
> On Tue, 27 Feb 2018 14:43:06 +0100
> Timo Walther <[hidden email]> wrote:
>
> TW> You can create it with org.apache.flink.table.api.Types.ROW(...).
> TW> You can check the type of your stream using ds.getType(). You can
> TW> pass information explicitly in Scala e.g. ds.map()(Types.ROW(...))
>
> thanks that works but now we're nailed to the types supported by
> `Types` which seem to be not that many (String, Int, Decimal, etc.).
>
> Is there a way to include custom types or at least something like UUID?
>
> Regards,
>
> Jens
>