Class: Google::Apis::DataprocV1::TaskData

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/dataproc_v1/classes.rb,
lib/google/apis/dataproc_v1/representations.rb,
lib/google/apis/dataproc_v1/representations.rb

Overview

Data corresponding to tasks created by spark.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ TaskData

Returns a new instance of TaskData.



11515
11516
11517
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11515

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#accumulator_updates ⇒ Array<Google::Apis::DataprocV1::AccumulableInfo>

Corresponds to the JSON property accumulatorUpdates

Returns:



11411
11412
11413
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11411

def accumulator_updates
  @accumulator_updates
end

#attempt ⇒ Fixnum

Corresponds to the JSON property attempt

Returns:

  • (Fixnum) 


11416
11417
11418
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11416

def attempt
  @attempt
end

#duration_millis ⇒ Fixnum

Corresponds to the JSON property durationMillis

Returns:

  • (Fixnum) 


11421
11422
11423
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11421

def duration_millis
  @duration_millis
end

#error_message ⇒ String

Corresponds to the JSON property errorMessage

Returns:

  • (String) 


11426
11427
11428
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11426

def error_message
  @error_message
end

#executor_id ⇒ String

Corresponds to the JSON property executorId

Returns:

  • (String) 


11431
11432
11433
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11431

def executor_id
  @executor_id
end

#executor_logs ⇒ Hash<String,String>

Corresponds to the JSON property executorLogs

Returns:

  • (Hash<String,String>) 


11436
11437
11438
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11436

def executor_logs
  @executor_logs
end

#getting_result_time_millis ⇒ Fixnum

Corresponds to the JSON property gettingResultTimeMillis

Returns:

  • (Fixnum) 


11441
11442
11443
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11441

def getting_result_time_millis
  @getting_result_time_millis
end

#has_metrics ⇒ Boolean Also known as: has_metrics?

Corresponds to the JSON property hasMetrics

Returns:

  • (Boolean) 


11446
11447
11448
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11446

def has_metrics
  @has_metrics
end

#host ⇒ String

Corresponds to the JSON property host

Returns:

  • (String) 


11452
11453
11454
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11452

def host
  @host
end

#index ⇒ Fixnum

Corresponds to the JSON property index

Returns:

  • (Fixnum) 


11457
11458
11459
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11457

def index
  @index
end

#launch_time ⇒ String

Corresponds to the JSON property launchTime

Returns:

  • (String) 


11462
11463
11464
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11462

def launch_time
  @launch_time
end

#partition_id ⇒ Fixnum

Corresponds to the JSON property partitionId

Returns:

  • (Fixnum) 


11467
11468
11469
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11467

def partition_id
  @partition_id
end

#result_fetch_start ⇒ String

Corresponds to the JSON property resultFetchStart

Returns:

  • (String) 


11472
11473
11474
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11472

def result_fetch_start
  @result_fetch_start
end

#scheduler_delay_millis ⇒ Fixnum

Corresponds to the JSON property schedulerDelayMillis

Returns:

  • (Fixnum) 


11477
11478
11479
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11477

def scheduler_delay_millis
  @scheduler_delay_millis
end

#speculative ⇒ Boolean Also known as: speculative?

Corresponds to the JSON property speculative

Returns:

  • (Boolean) 


11482
11483
11484
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11482

def speculative
  @speculative
end

#stage_attempt_id ⇒ Fixnum

Corresponds to the JSON property stageAttemptId

Returns:

  • (Fixnum) 


11488
11489
11490
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11488

def stage_attempt_id
  @stage_attempt_id
end

#stage_id ⇒ Fixnum

Corresponds to the JSON property stageId

Returns:

  • (Fixnum) 


11493
11494
11495
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11493

def stage_id
  @stage_id
end

#status ⇒ String

Corresponds to the JSON property status

Returns:

  • (String) 


11498
11499
11500
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11498

def status
  @status
end

#task_id ⇒ Fixnum

Corresponds to the JSON property taskId

Returns:

  • (Fixnum) 


11503
11504
11505
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11503

def task_id
  @task_id
end

#task_locality ⇒ String

Corresponds to the JSON property taskLocality

Returns:

  • (String) 


11508
11509
11510
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11508

def task_locality
  @task_locality
end

#task_metrics ⇒ Google::Apis::DataprocV1::TaskMetrics

Executor Task Metrics Corresponds to the JSON property taskMetrics

Returns:



11513
11514
11515
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11513

def task_metrics
  @task_metrics
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



11520
11521
11522
11523
11524
11525
11526
11527
11528
11529
11530
11531
11532
11533
11534
11535
11536
11537
11538
11539
11540
11541
11542
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11520

def update!(**args)
  @accumulator_updates = args[:accumulator_updates] if args.key?(:accumulator_updates)
  @attempt = args[:attempt] if args.key?(:attempt)
  @duration_millis = args[:duration_millis] if args.key?(:duration_millis)
  @error_message = args[:error_message] if args.key?(:error_message)
  @executor_id = args[:executor_id] if args.key?(:executor_id)
  @executor_logs = args[:executor_logs] if args.key?(:executor_logs)
  @getting_result_time_millis = args[:getting_result_time_millis] if args.key?(:getting_result_time_millis)
  @has_metrics = args[:has_metrics] if args.key?(:has_metrics)
  @host = args[:host] if args.key?(:host)
  @index = args[:index] if args.key?(:index)
  @launch_time = args[:launch_time] if args.key?(:launch_time)
  @partition_id = args[:partition_id] if args.key?(:partition_id)
  @result_fetch_start = args[:result_fetch_start] if args.key?(:result_fetch_start)
  @scheduler_delay_millis = args[:scheduler_delay_millis] if args.key?(:scheduler_delay_millis)
  @speculative = args[:speculative] if args.key?(:speculative)
  @stage_attempt_id = args[:stage_attempt_id] if args.key?(:stage_attempt_id)
  @stage_id = args[:stage_id] if args.key?(:stage_id)
  @status = args[:status] if args.key?(:status)
  @task_id = args[:task_id] if args.key?(:task_id)
  @task_locality = args[:task_locality] if args.key?(:task_locality)
  @task_metrics = args[:task_metrics] if args.key?(:task_metrics)
end