iceberg
iceberg copied to clipboard
Flink: Use Tag or Branch to scan data.
This PR is blocked on #4428
What is the purpose of the change
Scan data using a specified tag or branch.
Brief change log
Add the following syntax SQL:
* SELECT * FROM sample /*+ OPTIONS('tag'='t1')*/ ;
* SELECT * FROM sample /*+ OPTIONS('branch'='t1')*/ ;
API:
public Builder tag(String tag) {
contextBuilder.useTag(tag);
return this;
}
public Builder branch(String branch) {
contextBuilder.useBranch(branch);
return this;
}
public Builder startTag(String startTag) {
contextBuilder.startTag(startTag);
return this;
}
public Builder endTag(String endTag) {
contextBuilder.endTag(endTag);
return this;
}
cc @amogh-jahagirdar
This has a dependency on https://github.com/apache/iceberg/pull/4428/files, I will follow up on that PR.
As the core is being modified, this PR needs to wait for #5364 and #5475 to complete.
cc @amogh-jahagirdar @stevenzwu
cc @amogh-jahagirdar @stevenzwu @rdblue, could you please take a look when you are available?
@stevenzwu since you are reviewing #6660, could you also take a look at this?
@stevenzwu addressed the round of comments, PTAL, thx.
Looks like all comments are addressed and we have enough votes, thanks for the work @hililiwei , and thanks for the review @stevenzwu and @amogh-jahagirdar !
Thanks for the review @jackye1995 @stevenzwu @amogh-jahagirdar