How can we support something like a table that is partitioned with our processing?
Well, recall the discussion of the duality of tables and logs. This gives us exactly the tool to be able to convert streams to tables colocated with our processing, as well as a mechanism for handling fault tolerance for these tables.
A stream processor can keep its state in a local table or index: a bdb, RocksDB, or even something more unusual such as a Lucene or fastbit index. The contents of this store are fed from its input streams (after first perhaps applying arbitrary t...
stateful real-time processing
Share this highlighthttp://www.safaribooksonline.com/a/i-heart-logs/56810/