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
Is your feature request related to a problem? Please describe
A
StreamProducerintroduced 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
StreamProducerimplementation in java can have a parallel execution of streams whengetStream()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