trying to integrate bucket stream context into reducer framework