Re: Triggering emits for streaming window aggregates

2015-06-26 Thread Milinda Pathirage
Hi Yi, In this specific case ordering is declared in the schema. Quoting from Calcite documentation Monotonic columns need to be declared in the schema. The monotonicity is enforced when records enter the stream and assumed by queries that read from that stream. We recommend

Re: Triggering emits for streaming window aggregates

2015-06-26 Thread Yi Pan
Hi, Milinda, I thought that in your example, the ordering field is given in GROUP BY. Are we missing a way to pass the ordering field(s) to the LogicalAggregate? -Yi On Fri, Jun 26, 2015 at 10:49 AM, Milinda Pathirage wrote: > Hi Julian, > > Even though this is a general question across all th