Re: Review Request 32147: SAMZA-465

> On April 29, 2015, 7:30 p.m., Yan Fang wrote: > > samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java, > > line 149 > > > > > > Will this bootstrappedStreamSet overflow

Re: What next for streaming SQL?

Hi Julian, You are correct, I was referring to https://github.com/apache/incubator-calcite/blob/master/doc/STREAM.md#tumbling-windows. What I meant by "tumbling window size" was size of the window by seconds, minutes or hours. Its possible to deduce the size for an expression like "FLOOR(rowtime T

Re: What next for streaming SQL?

When I implemented this in the past, I found out that what I needed was not the window size exactly, but the next boundary value. For example, if I am using FLOOR(rowtime TO HOUR) and the current row is 10:03:00 then the next boundary will be 11:00:00. Once you have computed that boundary and st

Review Request 33735: RocksDB TTL support

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33735/ --- Review request for samza. Repository: samza Description --- RocksDB TTL

Re: Review Request 33735: RocksDB TTL support

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33735/#review82237 --- build.gradle