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 <j...@wegtam.com>: > Hi, > > On Tue, 27 Feb 2018 14:43:06 +0100 > Timo Walther <twal...@apache.org> 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 >
