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.



2789
2790
2791
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2789

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

Instance Attribute Details

#active_tasks ⇒ Fixnum

Corresponds to the JSON property activeTasks

Returns:

  • (Fixnum) 


2645
2646
2647
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2645

def active_tasks
  @active_tasks
end

#add_time ⇒ String

Corresponds to the JSON property addTime

Returns:

  • (String) 


2650
2651
2652
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2650

def add_time
  @add_time
end

#attributes ⇒ Hash<String,String>

Corresponds to the JSON property attributes

Returns:

  • (Hash<String,String>) 


2655
2656
2657
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2655

def attributes
  @attributes
end

#completed_tasks ⇒ Fixnum

Corresponds to the JSON property completedTasks

Returns:

  • (Fixnum) 


2660
2661
2662
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2660

def completed_tasks
  @completed_tasks
end

#disk_used ⇒ Fixnum

Corresponds to the JSON property diskUsed

Returns:

  • (Fixnum) 


2665
2666
2667
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2665

def disk_used
  @disk_used
end

#excluded_in_stages ⇒ Array<Fixnum>

Corresponds to the JSON property excludedInStages

Returns:

  • (Array<Fixnum>) 


2670
2671
2672
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2670

def excluded_in_stages
  @excluded_in_stages
end

#executor_id ⇒ String

Corresponds to the JSON property executorId

Returns:

  • (String) 


2675
2676
2677
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2675

def executor_id
  @executor_id
end

#executor_logs ⇒ Hash<String,String>

Corresponds to the JSON property executorLogs

Returns:

  • (Hash<String,String>) 


2680
2681
2682
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2680

def executor_logs
  @executor_logs
end

#failed_tasks ⇒ Fixnum

Corresponds to the JSON property failedTasks

Returns:

  • (Fixnum) 


2685
2686
2687
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2685

def failed_tasks
  @failed_tasks
end

#host_port ⇒ String

Corresponds to the JSON property hostPort

Returns:

  • (String) 


2690
2691
2692
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2690

def host_port
  @host_port
end

#is_active ⇒ Boolean Also known as: is_active?

Corresponds to the JSON property isActive

Returns:

  • (Boolean) 


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

def is_active
  @is_active
end

#is_excluded ⇒ Boolean Also known as: is_excluded?

Corresponds to the JSON property isExcluded

Returns:

  • (Boolean) 


2701
2702
2703
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2701

def is_excluded
  @is_excluded
end

#max_memory ⇒ Fixnum

Corresponds to the JSON property maxMemory

Returns:

  • (Fixnum) 


2707
2708
2709
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2707

def max_memory
  @max_memory
end

#max_tasks ⇒ Fixnum

Corresponds to the JSON property maxTasks

Returns:

  • (Fixnum) 


2712
2713
2714
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2712

def max_tasks
  @max_tasks
end

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

Corresponds to the JSON property memoryMetrics

Returns:



2717
2718
2719
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2717

def memory_metrics
  @memory_metrics
end

#memory_used ⇒ Fixnum

Corresponds to the JSON property memoryUsed

Returns:

  • (Fixnum) 


2722
2723
2724
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2722

def memory_used
  @memory_used
end

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

Corresponds to the JSON property peakMemoryMetrics

Returns:



2727
2728
2729
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2727

def peak_memory_metrics
  @peak_memory_metrics
end

#rdd_blocks ⇒ Fixnum

Corresponds to the JSON property rddBlocks

Returns:

  • (Fixnum) 


2732
2733
2734
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2732

def rdd_blocks
  @rdd_blocks
end

#remove_reason ⇒ String

Corresponds to the JSON property removeReason

Returns:

  • (String) 


2737
2738
2739
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2737

def remove_reason
  @remove_reason
end

#remove_time ⇒ String

Corresponds to the JSON property removeTime

Returns:

  • (String) 


2742
2743
2744
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2742

def remove_time
  @remove_time
end

#resource_profile_id ⇒ Fixnum

Corresponds to the JSON property resourceProfileId

Returns:

  • (Fixnum) 


2747
2748
2749
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2747

def resource_profile_id
  @resource_profile_id
end

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

Corresponds to the JSON property resources

Returns:



2752
2753
2754
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2752

def resources
  @resources
end

#total_cores ⇒ Fixnum

Corresponds to the JSON property totalCores

Returns:

  • (Fixnum) 


2757
2758
2759
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2757

def total_cores
  @total_cores
end

#total_duration_millis ⇒ Fixnum

Corresponds to the JSON property totalDurationMillis

Returns:

  • (Fixnum) 


2762
2763
2764
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2762

def total_duration_millis
  @total_duration_millis
end

#total_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property totalGcTimeMillis

Returns:

  • (Fixnum) 


2767
2768
2769
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2767

def total_gc_time_millis
  @total_gc_time_millis
end

#total_input_bytes ⇒ Fixnum

Corresponds to the JSON property totalInputBytes

Returns:

  • (Fixnum) 


2772
2773
2774
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2772

def total_input_bytes
  @total_input_bytes
end

#total_shuffle_read ⇒ Fixnum

Corresponds to the JSON property totalShuffleRead

Returns:

  • (Fixnum) 


2777
2778
2779
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2777

def total_shuffle_read
  @total_shuffle_read
end

#total_shuffle_write ⇒ Fixnum

Corresponds to the JSON property totalShuffleWrite

Returns:

  • (Fixnum) 


2782
2783
2784
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2782

def total_shuffle_write
  @total_shuffle_write
end

#total_tasks ⇒ Fixnum

Corresponds to the JSON property totalTasks

Returns:

  • (Fixnum) 


2787
2788
2789
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2787

def total_tasks
  @total_tasks
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2794
2795
2796
2797
2798
2799
2800
2801
2802
2803
2804
2805
2806
2807
2808
2809
2810
2811
2812
2813
2814
2815
2816
2817
2818
2819
2820
2821
2822
2823
2824
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2794

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