-
Notifications
You must be signed in to change notification settings - Fork 2.5k
Open
Labels
Search:PerformanceenhancementEnhancement or improvement to existing feature or requestEnhancement or improvement to existing feature or request
Description
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
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
Search:PerformanceenhancementEnhancement or improvement to existing feature or requestEnhancement or improvement to existing feature or request
Type
Projects
Status
🆕 New
Status
Todo