Xinyu Liu issues

Repositories
Issues
Comments

Results 1 issues of


                                            Xinyu Liu

Adds support in Samza Runner to run DoFn.processElement in parallel inside Samza tasks

This patch adds a thread pool in the DoFnRunner of Samza runner to execute DoFn.ProcessElement in parallel within a Samza task. This allows greater parallelism beyond a single task/partition. Users...

runners

samza