Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
morningman committed Aug 30, 2024
1 parent d0f8ffa commit a40beec
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -216,9 +216,6 @@ public static TFetchSchemaTableDataResult getMetadataTable(TFetchSchemaTableData
case TASKS:
result = taskMetadataResult(params);
break;
case META_CACHE_STATS:
result = metaCacheStatsMetadataResult(params);
break;
default:
return errorResult("Metadata table params is not set.");
}
Expand Down Expand Up @@ -268,6 +265,10 @@ public static TFetchSchemaTableDataResult getSchemaTableData(TFetchSchemaTableDa
result = tablePropertiesMetadataResult(schemaTableParams);
columnIndex = TABLE_PROPERTIES_COLUMN_TO_INDEX;
break;
case CATALOG_META_CACHE_STATS:
result = metaCacheStatsMetadataResult(schemaTableParams);
columnIndex = META_CACHE_STATS_COLUMN_TO_INDEX;
break;
default:
return errorResult("invalid schema table name.");
}
Expand Down Expand Up @@ -1264,11 +1265,7 @@ private static TFetchSchemaTableDataResult tablePropertiesMetadataResult(TSchema
return result;
}

private static TFetchSchemaTableDataResult metaCacheStatsMetadataResult(TMetadataTableRequestParams params) {
if (!params.isSetMetaCacheStatsParams()) {
return errorResult("meta cache stats params is not set.");
}

private static TFetchSchemaTableDataResult metaCacheStatsMetadataResult(TSchemaTableRequestParams params) {
List<TRow> dataBatch = Lists.newArrayList();
TFetchSchemaTableDataResult result = new TFetchSchemaTableDataResult();
for (CatalogIf catalogIf : Env.getCurrentEnv().getCatalogMgr().getCopyOfCatalog()) {
Expand Down
3 changes: 1 addition & 2 deletions gensrc/thrift/Types.thrift
Original file line number Diff line number Diff line change
Expand Up @@ -732,8 +732,7 @@ enum TMetadataType {
JOBS,
TASKS,
WORKLOAD_SCHED_POLICY,
PARTITIONS,
META_CACHE_STATS;
PARTITIONS;
}

enum TIcebergQueryType {
Expand Down

0 comments on commit a40beec

Please sign in to comment.