meshari343 opened a new issue, #13833:
URL: https://github.com/apache/pinot/issues/13833

   hello, I have noticed that DISTINCTCOUNT and percentile doesn't utilize 
indexes to filter data.
   
   below are the queries and their plan, based on the quick start airline 
dataset:
   
   1- DISTINCTCOUNT query:
   select DISTINCTCOUNT(Cancelled) from airlineStats where Origin = 'ATL'
   
   plan:
   "resultTable": {
     "dataSchema": {
       "columnNames": [
         "Operator",
         "Operator_Id",
         "Parent_Id"
       ],
       "columnDataTypes": [
         "STRING",
         "INT",
         "INT"
       ]
     },
     "rows": [
       [
         "BROKER_REDUCE(limit:10)",
         1,
         0
       ],
       [
         "COMBINE_AGGREGATE",
         2,
         1
       ],
       [
         "PLAN_START(numSegmentsForThisPlan:31)",
         -1,
         -1
       ],
       [
         "AGGREGATE(aggregations:distinctCount(Cancelled))",
         3,
         2
       ],
       [
         "PROJECT(Cancelled)",
         4,
         3
       ],
       [
         "DOC_ID_SET",
         5,
         4
       ],
       [
         "FILTER_FULL_SCAN(operator:EQ,predicate:Origin = 'ATL')",
         6,
         5
       ]
     ]
   }
   
   query response stats:
     "requestId": "93259971000000019",
     "brokerId": "Broker_172.17.0.2_8000",
     "exceptions": [],
     "numServersQueried": 1,
     "numServersResponded": 1,
     "numSegmentsQueried": 31,
     "numSegmentsProcessed": 31,
     "numSegmentsMatched": 31,
     "numConsumingSegmentsQueried": 0,
     "numConsumingSegmentsProcessed": 0,
     "numConsumingSegmentsMatched": 0,
     "numDocsScanned": 629,
     "numEntriesScannedInFilter": 9746,
     "numEntriesScannedPostFilter": 629,
     "numGroupsLimitReached": false,
     "totalDocs": 9746,
     "timeUsedMs": 10,
     "offlineThreadCpuTimeNs": 0,
     "realtimeThreadCpuTimeNs": 0,
     "offlineSystemActivitiesCpuTimeNs": 0,
     "realtimeSystemActivitiesCpuTimeNs": 0,
     "offlineResponseSerializationCpuTimeNs": 0,
     "realtimeResponseSerializationCpuTimeNs": 0,
     "offlineTotalCpuTimeNs": 0,
     "realtimeTotalCpuTimeNs": 0,
     "brokerReduceTimeMs": 0,
     "segmentStatistics": [],
     "traceInfo": {},
     "minConsumingFreshnessTimeMs": 0,
     "numRowsResultSet": 1,
     "numSegmentsPrunedByBroker": 0,
     "numSegmentsPrunedByServer": 0,
     "numSegmentsPrunedInvalid": 0,
     "numSegmentsPrunedByLimit": 0,
     "numSegmentsPrunedByValue": 0,
     "explainPlanNumEmptyFilterSegments": 0,
     "explainPlanNumMatchAllFilterSegments": 0
   
   
   2-percentile query:
   select percentile(AirTime, 50) from airlineStats where Origin = 'ATL'
   
   plan:
     "resultTable": {
       "dataSchema": {
         "columnNames": [
           "Operator",
           "Operator_Id",
           "Parent_Id"
         ],
         "columnDataTypes": [
           "STRING",
           "INT",
           "INT"
         ]
       },
       "rows": [
         [
           "BROKER_REDUCE(limit:10)",
           1,
           0
         ],
         [
           "COMBINE_AGGREGATE",
           2,
           1
         ],
         [
           "PLAN_START(numSegmentsForThisPlan:31)",
           -1,
           -1
         ],
         [
           "AGGREGATE(aggregations:percentile(AirTime))",
           3,
           2
         ],
         [
           "PROJECT(AirTime)",
           4,
           3
         ],
         [
           "DOC_ID_SET",
           5,
           4
         ],
         [
           "FILTER_FULL_SCAN(operator:EQ,predicate:Origin = 'ATL')",
           6,
           5
         ]
       ]
     }
   
   query response stats:
     "requestId": "93259971000000018",
     "brokerId": "Broker_172.17.0.2_8000",
     "exceptions": [],
     "numServersQueried": 1,
     "numServersResponded": 1,
     "numSegmentsQueried": 31,
     "numSegmentsProcessed": 31,
     "numSegmentsMatched": 31,
     "numConsumingSegmentsQueried": 0,
     "numConsumingSegmentsProcessed": 0,
     "numConsumingSegmentsMatched": 0,
     "numDocsScanned": 629,
     "numEntriesScannedInFilter": 9746,
     "numEntriesScannedPostFilter": 629,
     "numGroupsLimitReached": false,
     "totalDocs": 9746,
     "timeUsedMs": 10,
     "offlineThreadCpuTimeNs": 0,
     "realtimeThreadCpuTimeNs": 0,
     "offlineSystemActivitiesCpuTimeNs": 0,
     "realtimeSystemActivitiesCpuTimeNs": 0,
     "offlineResponseSerializationCpuTimeNs": 0,
     "realtimeResponseSerializationCpuTimeNs": 0,
     "offlineTotalCpuTimeNs": 0,
     "realtimeTotalCpuTimeNs": 0,
     "brokerReduceTimeMs": 0,
     "segmentStatistics": [],
     "traceInfo": {},
     "minConsumingFreshnessTimeMs": 0,
     "numRowsResultSet": 1,
     "numSegmentsPrunedByBroker": 0,
     "numSegmentsPrunedByServer": 0,
     "numSegmentsPrunedInvalid": 0,
     "numSegmentsPrunedByLimit": 0,
     "numSegmentsPrunedByValue": 0,
     "explainPlanNumEmptyFilterSegments": 0,
     "explainPlanNumMatchAllFilterSegments": 0
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to