Module transforming 

Modules

buffer

buffer_with_count

buffer_with_time

buffer_with_time_or_count

concat_map

flat_map

group_by

map

scan

switch_map

window

window_with_count