Re: Flink SQL API: Extra columns added from order by

2019-07-15 Thread Morrisa Brenner
ery If the return type is String, then >> ASC on a string value should be on alphabetical ordering. >> >> However on the third query, if the GROUP BY and ORDER BY are both >> operating on the same input to your UDF it shouldn't be part of the output >> columns. >

Flink SQL API: Extra columns added from order by

2019-07-11 Thread Morrisa Brenner
), sum(`testTable`.`count`) FROM `testTable` GROUP BY floor(`testTable`.`timestamp` TO MONTH) ORDER BY floor(`testTable`.`timestamp` TO MONTH) ASC Month SUM VALUE February 2019 1 2/1/2019 12:00 AM April 2019 1052 4/1/2019 12:00 AM -- Morrisa Brenner Software Engineer 225 Franklin St, Boston, MA 02110 klaviyo.com <https://www.klaviyo.com> [image: Klaviyo Logo]

Re: Generic return type on a user-defined scalar function

2019-05-24 Thread Morrisa Brenner
Hi JingsongLee and Timo, Thanks for taking a look and for the feedback! All the best, Morrisa Morrisa Brenner Software Engineer ━━ 225 Franklin St, Boston, MA 02110 klaviyo.com <https://www.klaviyo.com/> > On May 21, 2019, at 12:10 AM, JingsongLee wrote: > > Hi Morrisa

Generic return type on a user-defined scalar function

2019-05-16 Thread Morrisa Brenner
ignature) { return new TypeInformation[]{ TypeInformation.of(desiredType) }; } } -- Morrisa Brenner Software Engineer 225 Franklin St, Boston, MA 02110 klaviyo.com <https://www.klaviyo.com> [image: Klaviyo Logo]