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 <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
