Class: Google::Apis::DataprocV1::ExecutorMetricsDistributions

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ ExecutorMetricsDistributions

Returns a new instance of ExecutorMetricsDistributions.



2507
2508
2509
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2507

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

Instance Attribute Details

#disk_bytes_spilled ⇒ Array<Float>

Corresponds to the JSON property diskBytesSpilled

Returns:

  • (Array<Float>) 


2430
2431
2432
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2430

def disk_bytes_spilled
  @disk_bytes_spilled
end

#failed_tasks ⇒ Array<Float>

Corresponds to the JSON property failedTasks

Returns:

  • (Array<Float>) 


2435
2436
2437
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2435

def failed_tasks
  @failed_tasks
end

#input_bytes ⇒ Array<Float>

Corresponds to the JSON property inputBytes

Returns:

  • (Array<Float>) 


2440
2441
2442
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2440

def input_bytes
  @input_bytes
end

#input_records ⇒ Array<Float>

Corresponds to the JSON property inputRecords

Returns:

  • (Array<Float>) 


2445
2446
2447
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2445

def input_records
  @input_records
end

#killed_tasks ⇒ Array<Float>

Corresponds to the JSON property killedTasks

Returns:

  • (Array<Float>) 


2450
2451
2452
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2450

def killed_tasks
  @killed_tasks
end

#memory_bytes_spilled ⇒ Array<Float>

Corresponds to the JSON property memoryBytesSpilled

Returns:

  • (Array<Float>) 


2455
2456
2457
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2455

def memory_bytes_spilled
  @memory_bytes_spilled
end

#output_bytes ⇒ Array<Float>

Corresponds to the JSON property outputBytes

Returns:

  • (Array<Float>) 


2460
2461
2462
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2460

def output_bytes
  @output_bytes
end

#output_records ⇒ Array<Float>

Corresponds to the JSON property outputRecords

Returns:

  • (Array<Float>) 


2465
2466
2467
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2465

def output_records
  @output_records
end

#peak_memory_metrics ⇒ Google::Apis::DataprocV1::ExecutorPeakMetricsDistributions

Corresponds to the JSON property peakMemoryMetrics

Returns:



2470
2471
2472
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2470

def peak_memory_metrics
  @peak_memory_metrics
end

#quantiles ⇒ Array<Float>

Corresponds to the JSON property quantiles

Returns:

  • (Array<Float>) 


2475
2476
2477
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2475

def quantiles
  @quantiles
end

#shuffle_read ⇒ Array<Float>

Corresponds to the JSON property shuffleRead

Returns:

  • (Array<Float>) 


2480
2481
2482
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2480

def shuffle_read
  @shuffle_read
end

#shuffle_read_records ⇒ Array<Float>

Corresponds to the JSON property shuffleReadRecords

Returns:

  • (Array<Float>) 


2485
2486
2487
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2485

def shuffle_read_records
  @shuffle_read_records
end

#shuffle_write ⇒ Array<Float>

Corresponds to the JSON property shuffleWrite

Returns:

  • (Array<Float>) 


2490
2491
2492
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2490

def shuffle_write
  @shuffle_write
end

#shuffle_write_records ⇒ Array<Float>

Corresponds to the JSON property shuffleWriteRecords

Returns:

  • (Array<Float>) 


2495
2496
2497
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2495

def shuffle_write_records
  @shuffle_write_records
end

#succeeded_tasks ⇒ Array<Float>

Corresponds to the JSON property succeededTasks

Returns:

  • (Array<Float>) 


2500
2501
2502
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2500

def succeeded_tasks
  @succeeded_tasks
end

#task_time_millis ⇒ Array<Float>

Corresponds to the JSON property taskTimeMillis

Returns:

  • (Array<Float>) 


2505
2506
2507
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2505

def task_time_millis
  @task_time_millis
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2512
2513
2514
2515
2516
2517
2518
2519
2520
2521
2522
2523
2524
2525
2526
2527
2528
2529
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2512

def update!(**args)
  @disk_bytes_spilled = args[:disk_bytes_spilled] if args.key?(:disk_bytes_spilled)
  @failed_tasks = args[:failed_tasks] if args.key?(:failed_tasks)
  @input_bytes = args[:input_bytes] if args.key?(:input_bytes)
  @input_records = args[:input_records] if args.key?(:input_records)
  @killed_tasks = args[:killed_tasks] if args.key?(:killed_tasks)
  @memory_bytes_spilled = args[:memory_bytes_spilled] if args.key?(:memory_bytes_spilled)
  @output_bytes = args[:output_bytes] if args.key?(:output_bytes)
  @output_records = args[:output_records] if args.key?(:output_records)
  @peak_memory_metrics = args[:peak_memory_metrics] if args.key?(:peak_memory_metrics)
  @quantiles = args[:quantiles] if args.key?(:quantiles)
  @shuffle_read = args[:shuffle_read] if args.key?(:shuffle_read)
  @shuffle_read_records = args[:shuffle_read_records] if args.key?(:shuffle_read_records)
  @shuffle_write = args[:shuffle_write] if args.key?(:shuffle_write)
  @shuffle_write_records = args[:shuffle_write_records] if args.key?(:shuffle_write_records)
  @succeeded_tasks = args[:succeeded_tasks] if args.key?(:succeeded_tasks)
  @task_time_millis = args[:task_time_millis] if args.key?(:task_time_millis)
end