Wrap around cached data to InterruptibleIterator.
Made output of CoGroup and aggregations interruptible.