oopkQueryStats stores the overall stats for a query.
| 99 | |
| 100 | // oopkQueryStats stores the overall stats for a query. |
| 101 | type oopkQueryStats struct { |
| 102 | // stats for each stage. Sorted by total time. |
| 103 | stageStats []*oopkStageSummaryStats |
| 104 | // mapping from stage name to stage stats. |
| 105 | Name2Stage map[stageName]*oopkStageSummaryStats `json:"stages"` |
| 106 | |
| 107 | // Total timing for all query stages **including transfer**. |
| 108 | TotalTiming float64 `json:"latency"` |
| 109 | |
| 110 | // Total number of batches. |
| 111 | NumBatches int `json:"batches"` |
| 112 | // Total number of records processed on GPU. |
| 113 | // A record could represent multiple data record if firstColumn is compressed. |
| 114 | NumRecords int `json:"records"` |
| 115 | |
| 116 | // For archive batch, we skip process empty batch. For live batch, we will skip it |
| 117 | // if its min or max value does not pass main table filters or time filters. |
| 118 | NumBatchSkipped int `json:"numBatchSkipped"` |
| 119 | |
| 120 | // Stats for input data transferred via PCIe. |
| 121 | BytesTransferred int `json:"tranBytes"` |
| 122 | NumTransferCalls int `json:"tranCalls"` |
| 123 | } |
| 124 | |
| 125 | // NumRows implements the utils.TableDataSource for stats. |
| 126 | func (stats oopkQueryStats) NumRows() int { |
nothing calls this directly
no outgoing calls
no test coverage detected