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.



2882
2883
2884
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2882

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

Instance Attribute Details

#active_tasks ⇒ Fixnum

Corresponds to the JSON property activeTasks

Returns:

  • (Fixnum) 


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

def active_tasks
  @active_tasks
end

#add_time ⇒ String

Corresponds to the JSON property addTime

Returns:

  • (String) 


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

def add_time
  @add_time
end

#attributes ⇒ Hash<String,String>

Corresponds to the JSON property attributes

Returns:

  • (Hash<String,String>) 


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

def attributes
  @attributes
end

#completed_tasks ⇒ Fixnum

Corresponds to the JSON property completedTasks

Returns:

  • (Fixnum) 


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

def completed_tasks
  @completed_tasks
end

#disk_used ⇒ Fixnum

Corresponds to the JSON property diskUsed

Returns:

  • (Fixnum) 


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

def disk_used
  @disk_used
end

#excluded_in_stages ⇒ Array<Fixnum>

Corresponds to the JSON property excludedInStages

Returns:

  • (Array<Fixnum>) 


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

def excluded_in_stages
  @excluded_in_stages
end

#executor_id ⇒ String

Corresponds to the JSON property executorId

Returns:

  • (String) 


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

def executor_id
  @executor_id
end

#executor_logs ⇒ Hash<String,String>

Corresponds to the JSON property executorLogs

Returns:

  • (Hash<String,String>) 


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

def executor_logs
  @executor_logs
end

#failed_tasks ⇒ Fixnum

Corresponds to the JSON property failedTasks

Returns:

  • (Fixnum) 


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

def failed_tasks
  @failed_tasks
end

#host_port ⇒ String

Corresponds to the JSON property hostPort

Returns:

  • (String) 


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

def host_port
  @host_port
end

#is_active ⇒ Boolean Also known as: is_active?

Corresponds to the JSON property isActive

Returns:

  • (Boolean) 


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

def is_active
  @is_active
end

#is_excluded ⇒ Boolean Also known as: is_excluded?

Corresponds to the JSON property isExcluded

Returns:

  • (Boolean) 


2794
2795
2796
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2794

def is_excluded
  @is_excluded
end

#max_memory ⇒ Fixnum

Corresponds to the JSON property maxMemory

Returns:

  • (Fixnum) 


2800
2801
2802
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2800

def max_memory
  @max_memory
end

#max_tasks ⇒ Fixnum

Corresponds to the JSON property maxTasks

Returns:

  • (Fixnum) 


2805
2806
2807
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2805

def max_tasks
  @max_tasks
end

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

Corresponds to the JSON property memoryMetrics

Returns:



2810
2811
2812
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2810

def memory_metrics
  @memory_metrics
end

#memory_used ⇒ Fixnum

Corresponds to the JSON property memoryUsed

Returns:

  • (Fixnum) 


2815
2816
2817
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2815

def memory_used
  @memory_used
end

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

Corresponds to the JSON property peakMemoryMetrics

Returns:



2820
2821
2822
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2820

def peak_memory_metrics
  @peak_memory_metrics
end

#rdd_blocks ⇒ Fixnum

Corresponds to the JSON property rddBlocks

Returns:

  • (Fixnum) 


2825
2826
2827
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2825

def rdd_blocks
  @rdd_blocks
end

#remove_reason ⇒ String

Corresponds to the JSON property removeReason

Returns:

  • (String) 


2830
2831
2832
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2830

def remove_reason
  @remove_reason
end

#remove_time ⇒ String

Corresponds to the JSON property removeTime

Returns:

  • (String) 


2835
2836
2837
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2835

def remove_time
  @remove_time
end

#resource_profile_id ⇒ Fixnum

Corresponds to the JSON property resourceProfileId

Returns:

  • (Fixnum) 


2840
2841
2842
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2840

def resource_profile_id
  @resource_profile_id
end

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

Corresponds to the JSON property resources

Returns:



2845
2846
2847
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2845

def resources
  @resources
end

#total_cores ⇒ Fixnum

Corresponds to the JSON property totalCores

Returns:

  • (Fixnum) 


2850
2851
2852
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2850

def total_cores
  @total_cores
end

#total_duration_millis ⇒ Fixnum

Corresponds to the JSON property totalDurationMillis

Returns:

  • (Fixnum) 


2855
2856
2857
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2855

def total_duration_millis
  @total_duration_millis
end

#total_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property totalGcTimeMillis

Returns:

  • (Fixnum) 


2860
2861
2862
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2860

def total_gc_time_millis
  @total_gc_time_millis
end

#total_input_bytes ⇒ Fixnum

Corresponds to the JSON property totalInputBytes

Returns:

  • (Fixnum) 


2865
2866
2867
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2865

def total_input_bytes
  @total_input_bytes
end

#total_shuffle_read ⇒ Fixnum

Corresponds to the JSON property totalShuffleRead

Returns:

  • (Fixnum) 


2870
2871
2872
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2870

def total_shuffle_read
  @total_shuffle_read
end

#total_shuffle_write ⇒ Fixnum

Corresponds to the JSON property totalShuffleWrite

Returns:

  • (Fixnum) 


2875
2876
2877
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2875

def total_shuffle_write
  @total_shuffle_write
end

#total_tasks ⇒ Fixnum

Corresponds to the JSON property totalTasks

Returns:

  • (Fixnum) 


2880
2881
2882
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2880

def total_tasks
  @total_tasks
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2887
2888
2889
2890
2891
2892
2893
2894
2895
2896
2897
2898
2899
2900
2901
2902
2903
2904
2905
2906
2907
2908
2909
2910
2911
2912
2913
2914
2915
2916
2917
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2887

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