From 7ac52e117b72fbc4566fdc2e022693172417c5d5 Mon Sep 17 00:00:00 2001 From: kamijin_fanta Date: Tue, 12 Dec 2023 16:07:39 +0900 Subject: [PATCH] update stmtStats types --- trino/trino.go | 35 +++++++++++++++++++++-------------- 1 file changed, 21 insertions(+), 14 deletions(-) diff --git a/trino/trino.go b/trino/trino.go index 4b9db2c..fa99755 100644 --- a/trino/trino.go +++ b/trino/trino.go @@ -689,20 +689,27 @@ type stmtResponse struct { } type stmtStats struct { - State string `json:"state"` - Scheduled bool `json:"scheduled"` - Nodes int `json:"nodes"` - TotalSplits int `json:"totalSplits"` - QueuesSplits int `json:"queuedSplits"` - RunningSplits int `json:"runningSplits"` - CompletedSplits int `json:"completedSplits"` - UserTimeMillis int `json:"userTimeMillis"` - CPUTimeMillis int `json:"cpuTimeMillis"` - WallTimeMillis int `json:"wallTimeMillis"` - ProcessedRows int `json:"processedRows"` - ProcessedBytes int `json:"processedBytes"` - RootStage stmtStage `json:"rootStage"` - ProgressPercentage float32 `json:"progressPercentage"` + State string `json:"state"` + Scheduled bool `json:"scheduled"` + Nodes int `json:"nodes"` + TotalSplits int `json:"totalSplits"` + QueuesSplits int `json:"queuedSplits"` + RunningSplits int `json:"runningSplits"` + CompletedSplits int `json:"completedSplits"` + UserTimeMillis int `json:"userTimeMillis"` + CPUTimeMillis int64 `json:"cpuTimeMillis"` + WallTimeMillis int64 `json:"wallTimeMillis"` + QueuedTimeMillis int64 `json:"queuedTimeMillis"` + ElapsedTimeMillis int64 `json:"elapsedTimeMillis"` + ProcessedRows int64 `json:"processedRows"` + ProcessedBytes int64 `json:"processedBytes"` + PhysicalInputBytes int64 `json:"physicalInputBytes"` + PhysicalWrittenBytes int64 `json:"physicalWrittenBytes"` + PeakMemoryBytes int64 `json:"peakMemoryBytes"` + SpilledBytes int64 `json:"spilledBytes"` + RootStage stmtStage `json:"rootStage"` + ProgressPercentage float32 `json:"progressPercentage"` + RunningPercentage float32 `json:"runningPercentage"` } type stmtError struct {