Associative transducers for the parallel processing of streaming data