Class: TencentCloud::Dlc::V20210125::AnalysisTaskResults
- Inherits:
-
Common::AbstractModel
- Object
- Common::AbstractModel
- TencentCloud::Dlc::V20210125::AnalysisTaskResults
- Defined in:
- lib/v20210125/models.rb
Overview
洞察分析结果返回体
Instance Attribute Summary collapse
-
#AnalysisStatus ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#DataEngineName ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#Id ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#InputBytesSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#InputRecordsSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#InstanceCompleteTime ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#InstanceStartTime ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#JobTimeSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#OutputBytesSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#OutputFilesNum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#OutputRecordsSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#OutputSmallFilesNum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#ShuffleReadBytesSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#ShuffleReadRecordsSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#SQL ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#State ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
-
#TaskTimeSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。.
Instance Method Summary collapse
- #deserialize(params) ⇒ Object
-
#initialize(id = nil, instancestarttime = nil, instancecompletetime = nil, state = nil, sql = nil, dataenginename = nil, jobtimesum = nil, tasktimesum = nil, inputrecordssum = nil, inputbytessum = nil, outputrecordssum = nil, outputbytessum = nil, shufflereadbytessum = nil, shufflereadrecordssum = nil, analysisstatus = nil, outputfilesnum = nil, outputsmallfilesnum = nil) ⇒ AnalysisTaskResults
constructor
A new instance of AnalysisTaskResults.
Constructor Details
#initialize(id = nil, instancestarttime = nil, instancecompletetime = nil, state = nil, sql = nil, dataenginename = nil, jobtimesum = nil, tasktimesum = nil, inputrecordssum = nil, inputbytessum = nil, outputrecordssum = nil, outputbytessum = nil, shufflereadbytessum = nil, shufflereadrecordssum = nil, analysisstatus = nil, outputfilesnum = nil, outputsmallfilesnum = nil) ⇒ AnalysisTaskResults
455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 |
# File 'lib/v20210125/models.rb', line 455 def initialize(id=nil, instancestarttime=nil, instancecompletetime=nil, state=nil, sql=nil, dataenginename=nil, jobtimesum=nil, tasktimesum=nil, inputrecordssum=nil, inputbytessum=nil, outputrecordssum=nil, outputbytessum=nil, shufflereadbytessum=nil, shufflereadrecordssum=nil, analysisstatus=nil, outputfilesnum=nil, outputsmallfilesnum=nil) @Id = id @InstanceStartTime = instancestarttime @InstanceCompleteTime = instancecompletetime @State = state @SQL = sql @DataEngineName = dataenginename @JobTimeSum = jobtimesum @TaskTimeSum = tasktimesum @InputRecordsSum = inputrecordssum @InputBytesSum = inputbytessum @OutputRecordsSum = outputrecordssum @OutputBytesSum = outputbytessum @ShuffleReadBytesSum = shufflereadbytessum @ShuffleReadRecordsSum = shufflereadrecordssum @AnalysisStatus = analysisstatus @OutputFilesNum = outputfilesnum @OutputSmallFilesNum = outputsmallfilesnum end |
Instance Attribute Details
#AnalysisStatus ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def AnalysisStatus @AnalysisStatus end |
#DataEngineName ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def DataEngineName @DataEngineName end |
#Id ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def Id @Id end |
#InputBytesSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def InputBytesSum @InputBytesSum end |
#InputRecordsSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def InputRecordsSum @InputRecordsSum end |
#InstanceCompleteTime ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def InstanceCompleteTime @InstanceCompleteTime end |
#InstanceStartTime ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def InstanceStartTime @InstanceStartTime end |
#JobTimeSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def JobTimeSum @JobTimeSum end |
#OutputBytesSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def OutputBytesSum @OutputBytesSum end |
#OutputFilesNum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def OutputFilesNum @OutputFilesNum end |
#OutputRecordsSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def OutputRecordsSum @OutputRecordsSum end |
#OutputSmallFilesNum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def OutputSmallFilesNum @OutputSmallFilesNum end |
#ShuffleReadBytesSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def ShuffleReadBytesSum @ShuffleReadBytesSum end |
#ShuffleReadRecordsSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def ShuffleReadRecordsSum @ShuffleReadRecordsSum end |
#SQL ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def SQL @SQL end |
#State ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def State @State end |
#TaskTimeSum ⇒ Object
具体的:会统计任务的每个 Spark Stage 第一个 Task 到最后一个 Task 完成时长之和,不包含任务开始的排队耗时(即剔除从任务提交到 Spark Task 开始执行之间的调度等其他耗时),也不包含任务执行过程中多个 Spark Stage 之间因 executor 资源不足而等待执行 Task 所消耗的时间。
453 454 455 |
# File 'lib/v20210125/models.rb', line 453 def TaskTimeSum @TaskTimeSum end |
Instance Method Details
#deserialize(params) ⇒ Object
475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 |
# File 'lib/v20210125/models.rb', line 475 def deserialize(params) @Id = params['Id'] @InstanceStartTime = params['InstanceStartTime'] @InstanceCompleteTime = params['InstanceCompleteTime'] @State = params['State'] @SQL = params['SQL'] @DataEngineName = params['DataEngineName'] @JobTimeSum = params['JobTimeSum'] @TaskTimeSum = params['TaskTimeSum'] @InputRecordsSum = params['InputRecordsSum'] @InputBytesSum = params['InputBytesSum'] @OutputRecordsSum = params['OutputRecordsSum'] @OutputBytesSum = params['OutputBytesSum'] @ShuffleReadBytesSum = params['ShuffleReadBytesSum'] @ShuffleReadRecordsSum = params['ShuffleReadRecordsSum'] @AnalysisStatus = params['AnalysisStatus'] @OutputFilesNum = params['OutputFilesNum'] @OutputSmallFilesNum = params['OutputSmallFilesNum'] end |