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
