snapshot = loadTable("dfs://Level1", "Snapshot")
clearAllCache()
timer re1 = select [HINT_EXPLAIN] count(*) from snapshot group by SecurityID, bar(DateTime, 60)
为什么这个分组没有 reduce 阶段？是 HINT_EXPLAIN 的问题吗?\
string('{\n' +
' "measurement": "microsecond",\n' +
' "explain": {\n' +
' "from": {\n' +
' "cost": 2\n' +
' },\n' +
' "map": {\n' +
' "partitions": {\n' +
' "local": 20,\n' +
' "remote": 0\n' +
' },\n' +
' "cost": 256266,\n' +
' "detail": {\n' +
' "most": {\n' +
' "sql": "select [245771] count(*) as count from snapshot group by SecurityID,bar(DateTime, 60) as bar_DateTime [partition = /Level1/20200601/Key0/2]",\n' +
' "explain": {\n' +
' "groupBy": {\n' +
' "sortKey": false,\n' +
' "algo": "hash",\n' +
' "cost": 80455\n' +
' },\n' +
' "rows": 50094,\n' +
' "cost": 80494\n' +
' }\n' +
' },\n' +
' "least": {\n' +
' "sql": "select [245771] count(*) as count from snapshot group by SecurityID,bar(DateTime, 60) as bar_DateTime [partition = /Level1/20200602/Key8/2]",\n' +
' "explain": {\n' +
' "groupBy": {\n' +
' "sortKey": false,\n' +
' "algo": "hash",\n' +
' "cost": 33849\n' +
' },\n' +
' "rows": 45254,\n' +
' "cost": 33880\n' +
' }\n' +
' }\n' +
' }\n' +
' },\n' +
' "merge": {\n' +
' "cost": 4022,\n' +
' "rows": 968000,\n' +
' "detail": {\n' +
' "most": {\n' +
' "sql": "select [245771] count(*) as count from snapshot group by SecurityID,bar(DateTime, 60) as bar_DateTime [partition = /Level1/20200602/Key6/2]",\n' +
' "explain": {\n' +
' "groupBy": {\n' +
' "sortKey": false,\n' +
' "algo": "hash",\n' +
' "cost": 49660\n' +
' },\n' +
' "rows": 55418,\n' +
' "cost": 49695\n' +
' }\n' +
' },\n' +
' "least": {\n' +
' "sql": "select [245771] count(*) as count from snapshot group by SecurityID,bar(DateTime, 60) as bar_DateTime [partition = /Level1/20200601/Key2/2]",\n' +
' "explain": {\n' +
' "groupBy": {\n' +
' "sortKey": false,\n' +
' "algo": "hash",\n' +
' "cost": 74195\n' +
' },\n' +
' "rows": 44770,\n' +
' "cost": 74248\n' +
' }\n' +
' }\n' +
' }\n' +
' },\n' +
' "rows": 968000,\n' +
' "cost": 261320\n' +
' }\n' +
'}')