|
43 | 43 | public class ShowCacheHotSpotStmt extends ShowStmt implements NotFallbackInParser {
|
44 | 44 | public static final ShowResultSetMetaData[] RESULT_SET_META_DATAS = {
|
45 | 45 | ShowResultSetMetaData.builder()
|
46 |
| - .addColumn(new Column("cluster_id", ScalarType.createType(PrimitiveType.BIGINT))) |
47 |
| - .addColumn(new Column("cluster_name", ScalarType.createVarchar(128))) |
| 46 | + .addColumn(new Column("compute_group_id", ScalarType.createType(PrimitiveType.BIGINT))) |
| 47 | + .addColumn(new Column("compute_group_name", ScalarType.createVarchar(128))) |
48 | 48 | .addColumn(new Column("table_id", ScalarType.createType(PrimitiveType.BIGINT)))
|
49 | 49 | .addColumn(new Column("table_name", ScalarType.createVarchar(128)))
|
50 | 50 | .build(),
|
@@ -129,7 +129,8 @@ private String generateQueryString() {
|
129 | 129 | + "sum(query_per_week) as query_per_week_total "
|
130 | 130 | + "FROM " + TABLE_NAME.toString()
|
131 | 131 | + " group by cluster_id, cluster_name, table_id, table_name, insert_day) ");
|
132 |
| - StringBuilder q2 = new StringBuilder("select cluster_id, cluster_name, " |
| 132 | + StringBuilder q2 = new StringBuilder("select cluster_id as compute_group_id, " |
| 133 | + + "cluster_name as compute_group_name, " |
133 | 134 | + "table_id, table_name as hot_table_name from (select row_number() "
|
134 | 135 | + "over (partition by cluster_id order by insert_day desc, "
|
135 | 136 | + "query_per_day_total desc, query_per_week_total desc) as dr2, "
|
|
0 commit comments