com.twitter.summingbird.scalding.service
Reads the key log for this batch.
Reads the key log for this batch. By key log we mean a log of time, key and value when the key was written to. This is an associative operation and sufficient to scedule the service. This only has the keys that changed value during this batch.
A request must come in LESS than this window since the last key written to the service
This executes the join algortihm on the streams.
This executes the join algortihm on the streams. You are guaranteed that all the service data needed to do the join is present
The batched window never reads an aggregated last.
The batched window never reads an aggregated last. Instead we just output an empty pipe that is outside the window.
This is a service that has a finite memory. There is a materialized stream on disk, but the service only serves the data if: 0 < t(incoming key) - t(service key) < t(window) To use this you need to implement: windowSize readStream batcher ordering reducers