Skip to content

Commit 44676e5

Browse files
Core: Add metadata table for discovering metadata tables
1 parent 773907d commit 44676e5

40 files changed

Lines changed: 446 additions & 90 deletions

File tree

core/src/main/java/org/apache/iceberg/AllDataFilesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
public class AllDataFilesTable extends BaseFilesTable {
3131

3232
AllDataFilesTable(Table table) {
33-
this(table, table.name() + ".all_data_files");
33+
this(table, table.name() + "." + MetadataTableType.ALL_DATA_FILES.tableName());
3434
}
3535

3636
AllDataFilesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/AllDeleteFilesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
public class AllDeleteFilesTable extends BaseFilesTable {
3131

3232
AllDeleteFilesTable(Table table) {
33-
this(table, table.name() + ".all_delete_files");
33+
this(table, table.name() + "." + MetadataTableType.ALL_DELETE_FILES.tableName());
3434
}
3535

3636
AllDeleteFilesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/AllEntriesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
public class AllEntriesTable extends BaseEntriesTable {
3131

3232
AllEntriesTable(Table table) {
33-
this(table, table.name() + ".all_entries");
33+
this(table, table.name() + "." + MetadataTableType.ALL_ENTRIES.tableName());
3434
}
3535

3636
AllEntriesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/AllFilesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
public class AllFilesTable extends BaseFilesTable {
3131

3232
AllFilesTable(Table table) {
33-
this(table, table.name() + ".all_files");
33+
this(table, table.name() + "." + MetadataTableType.ALL_FILES.tableName());
3434
}
3535

3636
AllFilesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/AllManifestsTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ public class AllManifestsTable extends BaseMetadataTable {
8181
Types.NestedField.optional(19, "key_metadata", Types.BinaryType.get()));
8282

8383
AllManifestsTable(Table table) {
84-
this(table, table.name() + ".all_manifests");
84+
this(table, table.name() + "." + MetadataTableType.ALL_MANIFESTS.tableName());
8585
}
8686

8787
AllManifestsTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/DataFilesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
public class DataFilesTable extends BaseFilesTable {
2525

2626
DataFilesTable(Table table) {
27-
this(table, table.name() + ".data_files");
27+
this(table, table.name() + "." + MetadataTableType.DATA_FILES.tableName());
2828
}
2929

3030
DataFilesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/DeleteFilesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
public class DeleteFilesTable extends BaseFilesTable {
2525

2626
DeleteFilesTable(Table table) {
27-
this(table, table.name() + ".delete_files");
27+
this(table, table.name() + "." + MetadataTableType.DELETE_FILES.tableName());
2828
}
2929

3030
DeleteFilesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/FilesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
public class FilesTable extends BaseFilesTable {
2525

2626
FilesTable(Table table) {
27-
this(table, table.name() + ".files");
27+
this(table, table.name() + "." + MetadataTableType.FILES.tableName());
2828
}
2929

3030
FilesTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/HistoryTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public class HistoryTable extends BaseMetadataTable {
4242
Types.NestedField.required(4, "is_current_ancestor", Types.BooleanType.get()));
4343

4444
HistoryTable(Table table) {
45-
this(table, table.name() + ".history");
45+
this(table, table.name() + "." + MetadataTableType.HISTORY.tableName());
4646
}
4747

4848
HistoryTable(Table table, String name) {

core/src/main/java/org/apache/iceberg/ManifestEntriesTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
public class ManifestEntriesTable extends BaseEntriesTable {
3131

3232
ManifestEntriesTable(Table table) {
33-
this(table, table.name() + ".entries");
33+
this(table, table.name() + "." + MetadataTableType.ENTRIES.tableName());
3434
}
3535

3636
ManifestEntriesTable(Table table, String name) {

0 commit comments

Comments
 (0)