Thanks for the responses, much appreciated. I will continue to experiment.
Ben
On Sun Feb 15 2015 at 21:22:17 Julian Hyde wrote:
> +1
>
> As far as possible, behavior should be deterministic, that is, determined
> by the data rather than when the query was started or the arrival time of
> the d
+1
As far as possible, behavior should be deterministic, that is, determined by
the data rather than when the query was started or the arrival time of the
data.
Of course, for the query to make progress, there should be ways to discard late
data and to indicate that a producer is alive but do
Hi Benjamin,
I'm trying to employ samza for a similar use case and this is what I did
to mitigate this:
1> I have a notion of timestamp in the messages itself that I listen to.
This way, as I get messages, I can maintain state by time period of
aggregation by attaching the time period to the key
