com.twitter.summingbird.scalding.service
A request must come in LESS than this window since the last key written to the service
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.
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.
More familiar interface to scalding users that creates the Reader from two other methods