Re: Stream-Stream joins - restricting the size of the KV store

Hey Kishore, Right now, that has to be done by the application code. Our plan is to support a TTL in RocksDB once that feature is available to us in the Java JNI bindings (should be soon). In the meantime, you'll have to implement the WindowableTask.window() method, and call store.all() to periodi

Stream-Stream joins - restricting the size of the KV store

Hi all, I just read through this post about implementing streaming joins in Samza using a KV store that Samza provides. Can someone tell me how I can ensure that this KV storage does not grow too