Re: Window Semantics for Streams

As you know, streams.html is a specification. We do not claim that it is all implemented. Did you do a search of the existing tests? JdbcTest.testWinAgg2 features windows that have a variety of bounds, and produces the correct results. There are also tests in winagg.iq. I suspect that the

Re: Window Semantics for Streams

Hello, Can someone inform me if we can define the bounds of sliding windows with OVER in Calcite at this moment? I am trying to define sliding windows according to the examples given in https://calcite.apache .org/docs/stream.html and I keep getting wrong results. Some examples and the plans (I

Re: Calcite with Phoenix and Spark

If you want to go down the Pig adapter path, I will help on the Pig side. Thanks, Daniel On Wed, Nov 2, 2016 at 3:21 PM, Eli Levine wrote: > Will follow your suggested model when I start development. Thanks for > offering to potentially include that work in Calcite,

Re: Calcite with Phoenix and Spark

Will follow your suggested model when I start development. Thanks for offering to potentially include that work in Calcite, Julian. Eli On Tue, Nov 1, 2016 at 11:50 AM, Julian Hyde wrote: > If it helps make your “hope” a bit more likely to happen, you should > consider doing

Re: Calcite with Phoenix and Spark

It's a fairly loose term. For us it generally means being able to recover from node failures without having to rerun the process from the beginning. M/R, Spark fall broadly into that category. Thanks, Eli On Tue, Nov 1, 2016 at 11:46 AM, James Taylor wrote: > Eli, >