Hi Julian, I am +1 for merging chi branch to master. I think its better to have streaming related changes in 1.1 from the point of view of Samza.
Thanks Milinda On Sat, Mar 7, 2015 at 12:25 PM, Julian Hyde <[email protected]> wrote: > Milinda, > > Thanks for letting me know. The Statistic interface is a bit subtle > (well done for finding it). I'm still refining the stream SPI. I'll > make it simpler to define user-defined streams. > > By the way: The chi branch is fairly stable right now. Do you think I > should merge it into master so that it can be in the 1.1 release? It > doesn't include streaming joins, but it does include the streaming > scan, filter, project, aggregate, sort. Samza-sql can build on that, > and can always switch back to a calcite-chi snapshot if it needs a > feature that isn't in the release. > > Julian > > On Fri, Mar 6, 2015 at 7:59 PM, Milinda Pathirage <[email protected]> > wrote: > > Hi Julian, > > > > I found the issue. It was due to the missing getStatistic implementaiton > in > > the Table returned from my table factory. > > > > Thanks > > Milinda > > > > On Fri, Mar 6, 2015 at 5:08 PM, Milinda Pathirage <[email protected] > > > > wrote: > > > >> Hi Julian, > >> > >> Look like error was due to an old jar. Query went through parsing after > >> cleaning and rebuilding Calcite. But I am still getting > >> > >> "Streaming aggregation requires at least one monotonic expression in > GROUP > >> BY clause". > >> > >> Most probably this should be due to incompatibilities in my query > planner > >> code and new changes to 'chi' branch. I'll debug and see whats going on. > >> > >> Thanks for the help. > >> > >> Milinda > >> > >> On Fri, Mar 6, 2015 at 3:33 PM, Julian Hyde <[email protected]> > wrote: > >> > >>> We support “FLOOR(rowtime TO HOUR)”. The “TO” is part of the syntax of > >>> the FLOOR function, just as “AS” is part of the cast syntax “CAST(1.5 > AS > >>> DOUBLE)”. > >>> > >>> And we support the CEIL function: "CEIL(rowtime TO DAY)”. > >>> > >>> What query did you try? Did you re-generate the parser (“mvn clean”)? > >>> > >>> Julian > >>> > >>> > >>> On Mar 6, 2015, at 12:28 PM, Milinda Pathirage <[email protected]> > >>> wrote: > >>> > >>> > Hi Julian, > >>> > > >>> > Is expressions like 'rowtime TO HOUR' supported in 'chi' branch. I am > >>> > getting a parser error when I tried a sample query from > >>> > > https://github.com/julianhyde/incubator-calcite/blob/chi/doc/STREAM.md > >>> with > >>> > latest build from 'chi' branch. > >>> > > >>> > Thanks > >>> > Milinda > >>> > > >>> > > >>> > -- > >>> > Milinda Pathirage > >>> > > >>> > PhD Student | Research Assistant > >>> > School of Informatics and Computing | Data to Insight Center > >>> > Indiana University > >>> > > >>> > twitter: milindalakmal > >>> > skype: milinda.pathirage > >>> > blog: http://milinda.pathirage.org > >>> > >>> > >> > >> > >> -- > >> Milinda Pathirage > >> > >> PhD Student | Research Assistant > >> School of Informatics and Computing | Data to Insight Center > >> Indiana University > >> > >> twitter: milindalakmal > >> skype: milinda.pathirage > >> blog: http://milinda.pathirage.org > >> > > > > > > > > -- > > Milinda Pathirage > > > > PhD Student | Research Assistant > > School of Informatics and Computing | Data to Insight Center > > Indiana University > > > > twitter: milindalakmal > > skype: milinda.pathirage > > blog: http://milinda.pathirage.org > -- Milinda Pathirage PhD Student | Research Assistant School of Informatics and Computing | Data to Insight Center Indiana University twitter: milindalakmal skype: milinda.pathirage blog: http://milinda.pathirage.org
