可以通过函数getTabletsMeta()查看数据节点chunk的元数据信息,包含了chunk所在数据节点信息。
基于上述函数,封装一个该场景的查询函数:
def chunkDistribution(dbName, tbName){ return select count(*) from pnodeRun(getTabletsMeta{"/"+substr(dbName,6)+"/%",tbName,true,-1}) group by node } dbName = "dfs://testDB" tbName = "testTable" chunkDistribution(dbName, tbName)