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 :
> Hi,
>
>
Hi,
On Tue, 27 Feb 2018 15:20:00 +0100
Timo Walther wrote:
TW> you can always use TypeInformation.of() for all supported Flink
TW> types. In [1] you can also find a list of all types.
thank you very much for you help.
Regards,
Jens
--
CTO, Wegtam GmbH, 27. Hornung 2018, 15:23
Homepage : htt
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 schrie
Hi,
On Tue, 27 Feb 2018 14:43:06 +0100
Timo Walther 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
Hi Jens,
usually the Flink extracts the type information from the generic
signature of a function. E.g. it knows the fields of a Tuple2String>. The row type cannot be analyzed and therefore always needs
explicit information.
You can create it with org.apache.flink.table.api.Types.ROW(...). Yo
Hi,
I tried to create a table from a DataStream[Row] but got a (somehow
expected) error:
<---snip--->
An input of GenericTypeInfo cannot be converted to Table. Please
specify the type of the input with a RowTypeInfo.
<---snip--->
Code looks like this:
val ds: DataStream[Row] = ...
val dT = stre
