Re: TIMESTAMP TypeInformation

2016-10-27 Thread Greg Hogan
t;>>> >>>> E-mail: *radu.tudo...@huawei.com * >>>> >>>> Mobile: +49 15209084330 >>>> >>>> Telephone: +49 891588344173 >>>> >>>> >>>> >>>> HUAWEI TECHNOLOGIES Duesseldorf GmbH >>>&g

Re: TIMESTAMP TypeInformation

2016-10-27 Thread Fabian Hueske
> 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

Re: TIMESTAMP TypeInformation

2016-10-27 Thread Greg Hogan
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

RE: TIMESTAMP TypeInformation

2016-10-27 Thread Radu Tudoran
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

Re: TIMESTAMP TypeInformation

2016-10-27 Thread Fabian Hueske
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:

RE: TIMESTAMP TypeInformation

2016-10-27 Thread Radu Tudoran
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

Re: TIMESTAMP TypeInformation

2016-10-26 Thread Fabian Hueske
verted to GenericType. Anythoughts how I could > force the type to be recognize as a SqlTimeType? > > > > > > *From:* Radu Tudoran > *Sent:* Tuesday, October 25, 2016 4:46 PM > *To:* 'user@flink.apache.org' > *Subject:* TIMESTAMP TypeInformation >

RE: TIMESTAMP TypeInformation

2016-10-25 Thread Radu Tudoran
ill be converted to SqlTimeTypeInfo...but it is converted to GenericType. Anythoughts how I could force the type to be recognize as a SqlTimeType? From: Radu Tudoran Sent: Tuesday, October 25, 2016 4:46 PM To: 'user@flink.apache.org' Subject: TIMESTAMP TypeInformation Hi, I would

TIMESTAMP TypeInformation

2016-10-25 Thread Radu Tudoran
atch is of type ANY instead of being of type TIMESTAMP. Any thoughts of how to create the proper TIMESTAMP typeinformation?