-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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
Shortest path #4071
Shortest path #4071
Conversation
77c2aa4
to
69ad402
Compare
69ad402
to
ff044d1
Compare
66663a8
to
15f6102
Compare
9b23f13
to
0377451
Compare
Discussed it with Mingquan offline, it is compatible.
Cheers 🎉 |
is this merged on next version 3.2.0? |
yes, it's merged in master and I think will be |
@Reid00 Of course, it's in v3.2.0. The branch of v3.2.0 has not been pulled from master yet. |
yes. I noticed that. thank you @wey-gu @Shylock-Hg I will try this feature after v3.2.0 is released. |
What type of PR is this?
What problem(s) does this PR solve?
Issue(s) number:
Description:
Traverse the data in the CartesianProduct, and call the shortestPath function for each line. each call to the shortestPath function uses a thread to execute. then write result(matched path) to the index corresponding to the resultDs_ array. finally collect the data in the resultDs_ array in the collect stage and return
How do you solve it?
Special notes for your reviewer, ex. impact of this fix, design document, etc:
Checklist:
Tests:
Affects:
Release notes:
Please confirm whether to be reflected in release notes and how to describe: