-
Notifications
You must be signed in to change notification settings - Fork 1k
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
[core] Supports only execute specified actions during the writing process. #4884
base: master
Are you sure you want to change the base?
[core] Supports only execute specified actions during the writing process. #4884
Conversation
9d3fcef
to
ed49eb8
Compare
Thanks for @LinMingQiang prepare this pr. |
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.
Good job and left some comments.
7250389
to
b3867f8
Compare
+1 |
b3867f8
to
99dcebd
Compare
2d26f9d
to
fd50ccd
Compare
@JingsongLi PTAL, thanks! |
TAG_AUTOMATIC_CREATION("tag-automatic-creation"), | ||
|
||
// Actions during writing. | ||
MINOR_COMPACT("minor-compact"), |
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.
It is strange here, in streaming mode, it is hard to say just doing minor compact.
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.
We can only keep full-compact
and minor-compact
action can be removed. minor-compact
keep the original default logic.
|| doWriteActions.contains(WriteAction.PARTITION_EXPIRE); | ||
} | ||
|
||
public boolean doSnapshotExpireAction(Set<WriteAction> doWriteActions) { |
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.
All these methods can be in WriteAction
, they are just static methods.
fd50ccd
to
3702c60
Compare
Purpose
There are several operations during data writing such as
partition-expire
,snapshot-expire
,create-tag
...Currently, these actions are either executed together or not executed at all in the framework.
The purpose of this PR is to supports skipping specified actions during writing.
For example : set
'write.skip-actions'='partition-expire'
, the partition expiration action will be skipped during data writing, butsnapshot-expire
/auto create tag
/full compact
will still execute normally.Linked issue: close #xxx
Tests
API and Format
Documentation