Thanks Ram. This is helpful.
On Fri, Dec 23, 2016 at 9:30 PM, Munagala Ramanath
wrote:
> There are multiple approaches, each with its own tradeoffs. Here is first
> step:
>
> A1. Create a pair of in-memory non-transient queues to hold the tuples
> (non-transient
>because we want them to
There are multiple approaches, each with its own tradeoffs. Here is first
step:
A1. Create a pair of in-memory non-transient queues to hold the tuples
(non-transient
because we want them to be checkpointed and restored on recovery
from failure).
A2. Create a separate thread that waits for a
