Re: Using RowTypeInfo with Table API

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Using-RowTypeInfo-with-Table-API-tp18588p18596.html

Hi Jens,

you're not bound to the types supported by Types.
Types.ROW() accepts regular TypeInformation objects.
For example org.apache.flink.api.common.typeinfo.Types offers a few more types than org.apache.flink.table.api.Types.

Best, Fabian

2018-02-27 15:13 GMT+01:00 Jens Grassel <[hidden email]>:

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

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

We have lingered long enough on the shores of the Cosmic Ocean.
                -- Carl Sagan