add data parsing/processing module
move timeframe reduction to transform stream