samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Benjamin Edwards <>
Subject Re: Truncating rocks db
Date Mon, 16 Feb 2015 21:39:55 GMT
Yes, I was using a changelog. You bring up a good point. I think I need to
think harder about what I am trying to do. Maybe deleting all the keys
isn't that bad. Especially is I amortise it over the life of the next

It seems like waiting for TTLs is probably the right thing to do ultimately.

Thanks for the timely response!


On Sun Feb 15 2015 at 23:43:27 Chris Riccomini <>

> Hey Benjamin,
> You're right. Currently you have to call .all(), and delete everything.
> RocksDB just committed TTL support for their Java library. This feature
> allows data to automatically be expired out. Once RocksDB releases their
> TTL patch (I believe in a few weeks, according to Igor), we'll update Samza
> 0.9.0. Our tracker patch is here:
> > Is there no way to just say I don't care about the old data, gimme a new
> store?
> We don't have this feature right now, but we could add it. This feature is
> a bit more complicated when a changelog is attached, since we will have to
> execute deletes for every key (we still need to call .all()). Are you
> running with a changelog?
> Cheers,
> Chris
> On Sun, Feb 15, 2015 at 10:41 AM, Benjamin Edwards <
> >
> wrote:
> > Hi,
> >
> > I am trialling samza for some windowed stream processing. Typically I
> want
> > to aggregate a bunch of state over some window of messages, process the
> > data, then drop the current state. The only way that I can see to do that
> > at the moment is to delete every key. This seems expensive. Is there no
> way
> > to just say I don't care about the old data, gimme a new store?
> >
> > Ben
> >

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message