t;>>>
>>>> E-mail: *radu.tudo...@huawei.com *
>>>>
>>>> Mobile: +49 15209084330
>>>>
>>>> Telephone: +49 891588344173
>>>>
>>>>
>>>>
>>>> HUAWEI TECHNOLOGIES Duesseldorf GmbH
>>>&g
> HUAWEI TECHNOLOGIES Duesseldorf GmbH
>>> Hansaallee 205, 40549 Düsseldorf, Germany, www.huawei.com
>>> Registered Office: Düsseldorf, Register Court Düsseldorf, HRB 56063,
>>> Managing Director: Bo PENG, Wanzhou MENG, Lifang CHEN
>>> Sitz der Gesellschaft: D
s intended only for the person or entity whose address is
>> listed above. Any use of the information contained herein in any way
>> (including, but not limited to, total or partial disclosure, reproduction,
>> or dissemination) by persons other than the intended recipient(s) is
OK. I will open the JIRA
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Thursday, October 27, 2016 9:56 AM
To: user@flink.apache.org
Subject: Re: TIMESTAMP TypeInformation
Yes, I think you are right.
TypeInfoParser needs to be extended to parse the java.sql.* types into the
corresponding
semination) by persons other than the intended recipient(s) is
> prohibited. If you receive this e-mail in error, please notify the sender
> by phone or email immediately and delete it!
>
>
>
> *From:* Fabian Hueske [mailto:fhue...@gmail.com]
> *Sent:* Wednesday, October 26, 2016 10:
0:11 PM
To: user@flink.apache.org
Subject: Re: TIMESTAMP TypeInformation
Hi Radu,
I might not have complete understood your problem, but if you do
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tEnv = TableEnvironment.getTableEnvironment(env)
val ds = env.fromElements( (1, 1L, new Time
Hi Radu,
I might not have complete understood your problem, but if you do
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tEnv = TableEnvironment.getTableEnvironment(env)
val ds = env.fromElements( (1, 1L, new Time(1,2,3)) )
val t = ds.toTable(tEnv, 'a, 'b, 'c)
val results = t
Re-hi,
I actually realized that the problem comes from the fact that the datastream
that I am registering does not create properly the types.
I am using something like
DataStream ... .returns("TupleX<,,java.sql.Timestamp,
java.sql.Time>")...and I was expecting that these will be converted
