module Trino::Client::ModelVersions::V351::QueryStats
Public Class Methods
decode(hash)
click to toggle source
# File lib/trino/client/model_versions/351.rb, line 1733 def decode(hash) unless hash.is_a?(Hash) raise TypeError, "Can't convert #{hash.class} to Hash" end obj = allocate obj.send(:initialize_struct, hash["createTime"], hash["executionStartTime"], hash["lastHeartbeat"], hash["endTime"], hash["elapsedTime"], hash["queuedTime"], hash["resourceWaitingTime"], hash["dispatchingTime"], hash["executionTime"], hash["analysisTime"], hash["planningTime"], hash["finishingTime"], hash["totalTasks"], hash["runningTasks"], hash["completedTasks"], hash["totalDrivers"], hash["queuedDrivers"], hash["runningDrivers"], hash["blockedDrivers"], hash["completedDrivers"], hash["cumulativeUserMemory"], hash["userMemoryReservation"], hash["revocableMemoryReservation"], hash["totalMemoryReservation"], hash["peakUserMemoryReservation"], hash["peakRevocableMemoryReservation"], hash["peakNonRevocableMemoryReservation"], hash["peakTotalMemoryReservation"], hash["peakTaskUserMemory"], hash["peakTaskRevocableMemory"], hash["peakTaskTotalMemory"], hash["scheduled"], hash["totalScheduledTime"], hash["totalCpuTime"], hash["totalBlockedTime"], hash["fullyBlocked"], hash["blockedReasons"] && hash["blockedReasons"].map {|h| h.downcase.to_sym }, hash["physicalInputDataSize"], hash["physicalInputPositions"], hash["physicalInputReadTime"], hash["internalNetworkInputDataSize"], hash["internalNetworkInputPositions"], hash["rawInputDataSize"], hash["rawInputPositions"], hash["processedInputDataSize"], hash["processedInputPositions"], hash["outputDataSize"], hash["outputPositions"], hash["physicalWrittenDataSize"], hash["stageGcStatistics"] && hash["stageGcStatistics"].map {|h| StageGcStatistics.decode(h) }, hash["dynamicFiltersStats"] && DynamicFiltersStats.decode(hash["dynamicFiltersStats"]), hash["operatorSummaries"] && hash["operatorSummaries"].map {|h| OperatorStats.decode(h) }, ) obj end