@thatguymikeneal Just to clarify, do you want each map() step processing 1000 of the total (34,000) records? Ie, to only have 34 map steps run? And, the code snippet you sent, is that running in your map() stage? Or your getInputData() stage?