Add support for streaming rollups