start of a refac to streaming_hadoop_step to enable better hooks for testing

@kbarrette - please confirm that this doesn't re-break whatever the problem was in 560a689