Skip to content

Commit 2d377ba

Browse files
committed
can print now
1 parent d0d916d commit 2d377ba

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

fe/be-java-extensions/iceberg-metadata-scanner/src/main/java/org/apache/doris/iceberg/IcebergSnapshotsJniScanner.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -90,12 +90,13 @@ public void close() throws IOException {
9090
@Override
9191
protected HashMap<String, String> getMetadataSchema() {
9292
HashMap<String, String> metadataSchema = new HashMap<>();
93-
metadataSchema.put("committed_at", "long");
94-
metadataSchema.put("snapshot_id", "long");
95-
metadataSchema.put("parent_id", "long");
93+
// TODO: use decimal
94+
metadataSchema.put("committed_at", "bigint");
95+
metadataSchema.put("snapshot_id", "bigint");
96+
metadataSchema.put("parent_id", "bigint");
9697
metadataSchema.put("operation", "string");
9798
metadataSchema.put("manifest_list", "string");
98-
metadataSchema.put("summary", "string");
99+
metadataSchema.put("summary", "map<string,string>");
99100
return metadataSchema;
100101
}
101102

fe/fe-core/src/main/java/org/apache/doris/tablefunction/IcebergTableValuedFunction.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -58,12 +58,12 @@ public class IcebergTableValuedFunction extends MetadataTableValuedFunction {
5858
private static final ImmutableSet<String> PROPERTIES_SET = ImmutableSet.of(TABLE, QUERY_TYPE);
5959

6060
private static final ImmutableList<Column> SCHEMA_SNAPSHOT = ImmutableList.of(
61-
new Column("committed_at", PrimitiveType.DATETIMEV2, false),
61+
new Column("committed_at", PrimitiveType.BIGINT, false),
6262
new Column("snapshot_id", PrimitiveType.BIGINT, false),
6363
new Column("parent_id", PrimitiveType.BIGINT, false),
6464
new Column("operation", PrimitiveType.STRING, false),
65-
// todo: compress manifest_list string
6665
new Column("manifest_list", PrimitiveType.STRING, false),
66+
// TODO: use map type
6767
new Column("summary", PrimitiveType.STRING, false));
6868

6969
private static final ImmutableMap<String, Integer> COLUMN_TO_INDEX;
@@ -134,7 +134,6 @@ public TMetaScanRange getMetaScanRange() {
134134
// set iceberg metadata params
135135
TIcebergMetadataParams icebergMetadataParams = new TIcebergMetadataParams();
136136
icebergMetadataParams.setIcebergQueryType(queryType);
137-
// TODO: remove this after iceberg metadata cache is ready
138137
icebergMetadataParams.setCatalog(icebergTableName.getCtl());
139138
icebergMetadataParams.setDatabase(icebergTableName.getDb());
140139
icebergMetadataParams.setTable(icebergTableName.getTbl());

0 commit comments

Comments
 (0)