module PrestoLegacy::Client::Models::PipelineStats
Public Class Methods
decode(hash)
click to toggle source
# File lib/presto_legacy/client/models.rb, line 797 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["inputPipeline"], hash["outputPipeline"], hash["totalDrivers"], hash["queuedDrivers"], hash["queuedPartitionedDrivers"], hash["runningDrivers"], hash["runningPartitionedDrivers"], hash["completedDrivers"], hash["memoryReservation"], hash["systemMemoryReservation"], hash["queuedTime"] && DistributionSnapshot.decode(hash["queuedTime"]), hash["elapsedTime"] && DistributionSnapshot.decode(hash["elapsedTime"]), hash["totalScheduledTime"], hash["totalCpuTime"], hash["totalUserTime"], hash["totalBlockedTime"], hash["fullyBlocked"], hash["blockedReasons"] && hash["blockedReasons"].map {|h| h.downcase.to_sym }, hash["rawInputDataSize"], hash["rawInputPositions"], hash["processedInputDataSize"], hash["processedInputPositions"], hash["outputDataSize"], hash["outputPositions"], hash["operatorSummaries"] && hash["operatorSummaries"].map {|h| OperatorStats.decode(h) }, hash["drivers"] && hash["drivers"].map {|h| DriverStats.decode(h) }, ) obj end