-
Notifications
You must be signed in to change notification settings - Fork 3.5k
[feat](iceberg) Support read iceberg system tables #51190
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
[feat](iceberg) Support read iceberg system tables #51190
Conversation
Thank you for your contribution to Apache Doris. Please clearly describe your PR:
|
81d9772
to
e6d104a
Compare
00546ea
to
ebc5b6b
Compare
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/share/ManifestFileBean.java
Outdated
Show resolved
Hide resolved
fe/fe-core/src/main/java/org/apache/doris/datasource/tvf/source/MetadataScanNode.java
Show resolved
Hide resolved
cbaf083
to
4e4d0fa
Compare
d6d4044
to
a63ec3f
Compare
run buildall |
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
run buildall |
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
TPC-H: Total hot run time: 35374 ms
|
TPC-DS: Total hot run time: 190746 ms
|
ClickBench: Total hot run time: 29.17 s
|
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
BE Regression && UT Coverage ReportIncrement line coverage Increment coverage report
|
run buildall |
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
TPC-H: Total hot run time: 34200 ms
|
TPC-DS: Total hot run time: 196014 ms
|
BE Regression && UT Coverage ReportIncrement line coverage Increment coverage report
|
impl IcebergMetadataColumnValue impl IcebergSnapshotsJniScanner impl IcebergMetadataJniReader impl fe fix build fix set hadoop_props fix build again refactor fix refactor again impl IcebergFilesJniScanner impl IcebergHistoryJniScanner fix checkstyle support complex type fix pom.xm and flush out impl IcebergSysTable.getSupportedIcebergSysTables clean unusefule code support multiple ranges for MetadataTableValuedFunction refactor IcebergTableValuedFunction impl IcebergFilesTableValuedFunction fix checkstyle and build fe fix build fix files table impl IcebergManifestsJniScanner and IcebergRefsJniScanner fix IcebergMetadataJniReader complete IcebergTableValuedFunctions fix impl IcebergMetadataLogEntriesJniScanner impl IcebergPositionDeletesJniScanner fix fix fix and make iceberg sys table schema nullable fix and print datatime with scale=3 fix fix manifest fix position_deletes and add comment add data_files and deelte_files table and schema info get schema from iceberg api in IcebergTableValuedFunction fix and clean iceberg_jni_reader remove getMetadataSchema move get_next_block and get_next_block to common JniReader set time_zone fix build fix LakeSoulJniReader fix fix Partitions test new IcebergEntriesJniScanner refactor IcebergMetadataJniScanners to IcebergSysTableJniScanner refact IcebergTableValuedFunction supprot select required fileds for icebergSysTable fix fix select column support parse ByteBuffer fix print datatime remove ManifestFileBean foreach MetadataTableType to create SUPPORTED_ICEBERG_SYS_TABLES selectSchema in IcebergSysTableJniScanner fix add regression clean code fix oom add regressions test exception fix parse ByteBuffer make regression stable clean code
fix build fix rebase error fix external merge
50a71ea
to
89d3551
Compare
run buildall |
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
TPC-H: Total hot run time: 33851 ms
|
TPC-DS: Total hot run time: 185632 ms
|
ClickBench: Total hot run time: 29.34 s
|
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
BE Regression && UT Coverage ReportIncrement line coverage Increment coverage report
|
PR approved by at least one committer and no changes requested. |
PR approved by anyone and no changes requested. |
Support read iceberg system tables. See https://iceberg.apache.org/docs/nightly/spark-queries/#inspecting-tables Example: ``` select * from table$all_files; ```
Support read iceberg system tables. See https://iceberg.apache.org/docs/nightly/spark-queries/#inspecting-tables Example: ``` select * from table$all_files; ```
Support read iceberg system tables. See https://iceberg.apache.org/docs/nightly/spark-queries/#inspecting-tables Example: ``` select * from table$all_files; ```
relate pr: apache/doris#51190 ## Versions - [x] dev - [ ] 3.0 - [ ] 2.1 - [ ] 2.0 ## Languages - [x] Chinese - [x] English ## Docs Checklist - [ ] Checked by AI - [ ] Test Cases Built --------- Co-authored-by: Mingyu Chen (Rayner) <[email protected]>
Support read iceberg system tables. See https://iceberg.apache.org/docs/nightly/spark-queries/#inspecting-tables Example: ``` select * from table$all_files; ```
Support read iceberg system tables. See https://iceberg.apache.org/docs/nightly/spark-queries/#inspecting-tables Example: ``` select * from table$all_files; ```
What problem does this PR solve?
Support read iceberg system tables.
See https://iceberg.apache.org/docs/nightly/spark-queries/#inspecting-tables
Example:
Release note
None
Check List (For Author)
Test
Behavior changed:
Does this need documentation?
Check List (For Reviewer who merge this PR)