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.

Sign up for GitHub

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

Jump to bottom

[Feature Request] Partitioned stream support in Stream framework #17493

Open
rishabhmaurya opened this issue Feb 28, 2025 · 0 comments
Open

[Feature Request] Partitioned stream support in Stream framework #17493

rishabhmaurya opened this issue Feb 28, 2025 · 0 comments
Labels
enhancement Enhancement or improvement to existing feature or request Search:Performance untriaged

Comments

@rishabhmaurya
Copy link
Contributor

Is your feature request related to a problem? Please describe

A StreamProducer introduced in #16691 could produce multiple streams as part of one job.

Describe the solution you'd like

we can create something like PartitionedStreamTicket, which will internally contain list of tickets.
Its StreamProducer implementation in java can have a parallel execution of streams when getStream() is called on it.
For getFlightInfo() it can just return List of endpoints, as your POC code.

Related component

Search:Performance

Describe alternatives you've considered

No response

Additional context

No response
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
enhancement Enhancement or improvement to existing feature or request Search:Performance untriaged
Projects
Performance Roadmap
Status: Todo
Search Project Board
Status: 🆕 New
Milestone
No milestone
Development

No branches or pull requests
1 participant
@rishabhmaurya