Hi Shekar, Need a little more clarification.
What do you mean by "a local cache"? Is it a db like MySQL, something like RocksDB, or even just in-memory? When you say "another topic", is this the topic consumed by the same Samza job as your 5-minutes-job, or in a separate job? What is the relation between the topic and the application name? Thanks, Fang, Yan yanfang...@gmail.com On Fri, Jun 26, 2015 at 1:08 AM, Shekar Tippur <ctip...@gmail.com> wrote: > Hello, > My apologies if I have raised it earlier. > Here is the use case: > I have a stream that is partitioned based on application name. I want to be > able to count hte number of events happening for that particular > application in the past 5 minutes (sliding window) and update either > another topic or a local cache. > > Is this possible via 0.9 version of Samza? > If not, what is the easiest way to achieve this? > > - Shekar >
