Add Continue support to StreamingAggregator