Class: Google::Apis::DataprocV1::ExecutorSummary

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

Details about executors used by the application.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ ExecutorSummary

Returns a new instance of ExecutorSummary.



2695
2696
2697
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2695

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

Instance Attribute Details

#active_tasks ⇒ Fixnum

Corresponds to the JSON property activeTasks

Returns:

  • (Fixnum) 


2551
2552
2553
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2551

def active_tasks
  @active_tasks
end

#add_time ⇒ String

Corresponds to the JSON property addTime

Returns:

  • (String) 


2556
2557
2558
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2556

def add_time
  @add_time
end

#attributes ⇒ Hash<String,String>

Corresponds to the JSON property attributes

Returns:

  • (Hash<String,String>) 


2561
2562
2563
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2561

def attributes
  @attributes
end

#completed_tasks ⇒ Fixnum

Corresponds to the JSON property completedTasks

Returns:

  • (Fixnum) 


2566
2567
2568
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2566

def completed_tasks
  @completed_tasks
end

#disk_used ⇒ Fixnum

Corresponds to the JSON property diskUsed

Returns:

  • (Fixnum) 


2571
2572
2573
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2571

def disk_used
  @disk_used
end

#excluded_in_stages ⇒ Array<Fixnum>

Corresponds to the JSON property excludedInStages

Returns:

  • (Array<Fixnum>) 


2576
2577
2578
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2576

def excluded_in_stages
  @excluded_in_stages
end

#executor_id ⇒ String

Corresponds to the JSON property executorId

Returns:

  • (String) 


2581
2582
2583
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2581

def executor_id
  @executor_id
end

#executor_logs ⇒ Hash<String,String>

Corresponds to the JSON property executorLogs

Returns:

  • (Hash<String,String>) 


2586
2587
2588
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2586

def executor_logs
  @executor_logs
end

#failed_tasks ⇒ Fixnum

Corresponds to the JSON property failedTasks

Returns:

  • (Fixnum) 


2591
2592
2593
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2591

def failed_tasks
  @failed_tasks
end

#host_port ⇒ String

Corresponds to the JSON property hostPort

Returns:

  • (String) 


2596
2597
2598
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2596

def host_port
  @host_port
end

#is_active ⇒ Boolean Also known as: is_active?

Corresponds to the JSON property isActive

Returns:

  • (Boolean) 


2601
2602
2603
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2601

def is_active
  @is_active
end

#is_excluded ⇒ Boolean Also known as: is_excluded?

Corresponds to the JSON property isExcluded

Returns:

  • (Boolean) 


2607
2608
2609
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2607

def is_excluded
  @is_excluded
end

#max_memory ⇒ Fixnum

Corresponds to the JSON property maxMemory

Returns:

  • (Fixnum) 


2613
2614
2615
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2613

def max_memory
  @max_memory
end

#max_tasks ⇒ Fixnum

Corresponds to the JSON property maxTasks

Returns:

  • (Fixnum) 


2618
2619
2620
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2618

def max_tasks
  @max_tasks
end

#memory_metrics ⇒ Google::Apis::DataprocV1::MemoryMetrics

Corresponds to the JSON property memoryMetrics

Returns:



2623
2624
2625
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2623

def memory_metrics
  @memory_metrics
end

#memory_used ⇒ Fixnum

Corresponds to the JSON property memoryUsed

Returns:

  • (Fixnum) 


2628
2629
2630
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2628

def memory_used
  @memory_used
end

#peak_memory_metrics ⇒ Google::Apis::DataprocV1::ExecutorMetrics

Corresponds to the JSON property peakMemoryMetrics

Returns:



2633
2634
2635
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2633

def peak_memory_metrics
  @peak_memory_metrics
end

#rdd_blocks ⇒ Fixnum

Corresponds to the JSON property rddBlocks

Returns:

  • (Fixnum) 


2638
2639
2640
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2638

def rdd_blocks
  @rdd_blocks
end

#remove_reason ⇒ String

Corresponds to the JSON property removeReason

Returns:

  • (String) 


2643
2644
2645
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2643

def remove_reason
  @remove_reason
end

#remove_time ⇒ String

Corresponds to the JSON property removeTime

Returns:

  • (String) 


2648
2649
2650
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2648

def remove_time
  @remove_time
end

#resource_profile_id ⇒ Fixnum

Corresponds to the JSON property resourceProfileId

Returns:

  • (Fixnum) 


2653
2654
2655
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2653

def resource_profile_id
  @resource_profile_id
end

#resources ⇒ Hash<String,Google::Apis::DataprocV1::ResourceInformation>

Corresponds to the JSON property resources

Returns:



2658
2659
2660
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2658

def resources
  @resources
end

#total_cores ⇒ Fixnum

Corresponds to the JSON property totalCores

Returns:

  • (Fixnum) 


2663
2664
2665
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2663

def total_cores
  @total_cores
end

#total_duration_millis ⇒ Fixnum

Corresponds to the JSON property totalDurationMillis

Returns:

  • (Fixnum) 


2668
2669
2670
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2668

def total_duration_millis
  @total_duration_millis
end

#total_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property totalGcTimeMillis

Returns:

  • (Fixnum) 


2673
2674
2675
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2673

def total_gc_time_millis
  @total_gc_time_millis
end

#total_input_bytes ⇒ Fixnum

Corresponds to the JSON property totalInputBytes

Returns:

  • (Fixnum) 


2678
2679
2680
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2678

def total_input_bytes
  @total_input_bytes
end

#total_shuffle_read ⇒ Fixnum

Corresponds to the JSON property totalShuffleRead

Returns:

  • (Fixnum) 


2683
2684
2685
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2683

def total_shuffle_read
  @total_shuffle_read
end

#total_shuffle_write ⇒ Fixnum

Corresponds to the JSON property totalShuffleWrite

Returns:

  • (Fixnum) 


2688
2689
2690
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2688

def total_shuffle_write
  @total_shuffle_write
end

#total_tasks ⇒ Fixnum

Corresponds to the JSON property totalTasks

Returns:

  • (Fixnum) 


2693
2694
2695
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2693

def total_tasks
  @total_tasks
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2700
2701
2702
2703
2704
2705
2706
2707
2708
2709
2710
2711
2712
2713
2714
2715
2716
2717
2718
2719
2720
2721
2722
2723
2724
2725
2726
2727
2728
2729
2730
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2700

def update!(**args)
  @active_tasks = args[:active_tasks] if args.key?(:active_tasks)
  @add_time = args[:add_time] if args.key?(:add_time)
  @attributes = args[:attributes] if args.key?(:attributes)
  @completed_tasks = args[:completed_tasks] if args.key?(:completed_tasks)
  @disk_used = args[:disk_used] if args.key?(:disk_used)
  @excluded_in_stages = args[:excluded_in_stages] if args.key?(:excluded_in_stages)
  @executor_id = args[:executor_id] if args.key?(:executor_id)
  @executor_logs = args[:executor_logs] if args.key?(:executor_logs)
  @failed_tasks = args[:failed_tasks] if args.key?(:failed_tasks)
  @host_port = args[:host_port] if args.key?(:host_port)
  @is_active = args[:is_active] if args.key?(:is_active)
  @is_excluded = args[:is_excluded] if args.key?(:is_excluded)
  @max_memory = args[:max_memory] if args.key?(:max_memory)
  @max_tasks = args[:max_tasks] if args.key?(:max_tasks)
  @memory_metrics = args[:memory_metrics] if args.key?(:memory_metrics)
  @memory_used = args[:memory_used] if args.key?(:memory_used)
  @peak_memory_metrics = args[:peak_memory_metrics] if args.key?(:peak_memory_metrics)
  @rdd_blocks = args[:rdd_blocks] if args.key?(:rdd_blocks)
  @remove_reason = args[:remove_reason] if args.key?(:remove_reason)
  @remove_time = args[:remove_time] if args.key?(:remove_time)
  @resource_profile_id = args[:resource_profile_id] if args.key?(:resource_profile_id)
  @resources = args[:resources] if args.key?(:resources)
  @total_cores = args[:total_cores] if args.key?(:total_cores)
  @total_duration_millis = args[:total_duration_millis] if args.key?(:total_duration_millis)
  @total_gc_time_millis = args[:total_gc_time_millis] if args.key?(:total_gc_time_millis)
  @total_input_bytes = args[:total_input_bytes] if args.key?(:total_input_bytes)
  @total_shuffle_read = args[:total_shuffle_read] if args.key?(:total_shuffle_read)
  @total_shuffle_write = args[:total_shuffle_write] if args.key?(:total_shuffle_write)
  @total_tasks = args[:total_tasks] if args.key?(:total_tasks)
end