-
Notifications
You must be signed in to change notification settings - Fork 3.4k
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
[Refactor][Load]Unify common part in streamLoad and loadingTask planner #19118
Conversation
|
||
protected DescriptorTable descTable; | ||
|
||
public void preparePlan(List<List<TBrokerFileStatus>> fileStatusesList, int filesAdded) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If we use insert into select to replace current stream load logic, this planner maybe useless....
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Sorry,I don't quite understand the meaning of your comment in this line. I think the streamloadplanner won't call the prepareplan method, it's just abstracted out to unify the plan method.old is plan(TUniqueId loadId, List<List> fileStatusesList, int filesAdded),now plan(TUniqueId loadId),the purpose of this pr is only to unify common part in streamLoad and loadingTask planner,there is no logical modification.
run p0 |
run buildall |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
fe/fe-core/src/main/java/org/apache/doris/planner/external/LoadPlanner.java
Show resolved
Hide resolved
run buildall |
Proposed changes
Issue Number: #18476
Please only focus on streamLoadPlanner LoadingTaskPlanner and LoadPlanner