Hi all,

I just read through this post
<http://samza.apache.org/learn/documentation/0.7.0/container/state-management.html#stream-stream-join>
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 large (even though I know that this is on disk)? Does Samza
provide a way to purge older keys, or is that expected to be done by the
application code?

Thanks.

KN.

Reply via email to