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