Ayende @ Rahien

It's a girl

Raven Streams architecture thoughts: Storage

Raven Streams is a working title.

So far, I have been working mostly on getting things working from an infrastructure perspective. That is, I want to be able to successfully write & read from the streams, and I have a general architecture for it.

Basically, we have something like this:

image

This is a single stream (of which we expect to have more than one, but not a very high number). The stream makes all writes to a mem table, backed by a log. When the mem table is full, we switch to a new memtable and write all the data to a sorted string table (SST). This is very much like the design of leveldb.

Internally, however, we represent all data as etags. That is, you don’t have an actual key that you can use, the stream will generate an etag for you. And the SST are sorted in order, so the oldest events are in the oldest file, etc.

On startup, if we haven’t flushed properly, we will translate the log file into a new SST and start from scratch. I am not sure yet if we want / need to implement compaction. Maybe we will do that for very small files only.

Right now there are two methods that you actually care about:

  • AppendAsync(data)
  • ReadFrom(etag)

This is how you use them:

   1: for (int i = 0; i < 15; i++)
   2: {
   3:     eventStream.AppendAsync(new RavenJObject { { "counter", i } }).Wait();
   4: }
   5:  
   6: int x = 0;
   7: foreach (var item in eventStream.ReadFrom(Etag.Empty))
   8: {
   9:     var value = item.Value<int>("counter");
  10:     Assert.Equal(x++, value);
  11: }

This is all working pretty nicely right now. It isn’t nearly ready for production or even test usage, but this is encouraging. Next, I’ll discuss the intended implementation of map/reduce against this.

Tags:

Posted By: Ayende Rahien

Published at

Originally posted at

Comments

Daniel Marbach
06/04/2013 06:40 PM by
Daniel Marbach

Oren, why don't you just hire greg youngs event store team and use their knowledge to build blazing fast storage engine. Performance vise I doubt your solution can compete with that. Why reinvent the wheel?

Ayende Rahien
06/06/2013 10:19 AM by
Ayende Rahien

Daniel, Because we aren't talking about the same thing. I am not trying to create an event store.

Daniel Marbach
06/06/2013 11:26 AM by
Daniel Marbach

Yeah but you need fast and transactional appen only store or not? That is present there

Ayende Rahien
06/06/2013 11:28 AM by
Ayende Rahien

Daniel, Different things altogether. One append only store doesn't match the needs of another.

Comments have been closed on this topic.