added grouping + store as JSON, followed by group processing with R streaming