Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Concurrency: parallel blocking Sink #17

Open
eledhwen opened this issue Mar 6, 2024 · 0 comments
Open

Concurrency: parallel blocking Sink #17

eledhwen opened this issue Mar 6, 2024 · 0 comments

Comments

@eledhwen
Copy link
Collaborator

eledhwen commented Mar 6, 2024

It should be possible to run Sinks in a parallel fashion while still requiring them to be completed before exiting the pipeline.

Current implementation makes a distinction between serial synchronous and parallel asynchronous ; instead we most often want parallel synchronous and parallel asynchronous.
This can be straightforward to implement using the Future API.

It should be noted however that this requires additional attention to the ServiceExecutor: making most/all Sink parallel requires appropriate sizing, and possibly thread pooling between pipelines. We can already make such adjustments via the setSinkExecutor and setSinkExecutorProvider methods on the pipeline builders, but it may need to be better integrated.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant