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.



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

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

Instance Attribute Details

#active_tasks ⇒ Fixnum

Corresponds to the JSON property activeTasks

Returns:

  • (Fixnum) 


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

def active_tasks
  @active_tasks
end

#add_time ⇒ String

Corresponds to the JSON property addTime

Returns:

  • (String) 


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

def add_time
  @add_time
end

#attributes ⇒ Hash<String,String>

Corresponds to the JSON property attributes

Returns:

  • (Hash<String,String>) 


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

def attributes
  @attributes
end

#completed_tasks ⇒ Fixnum

Corresponds to the JSON property completedTasks

Returns:

  • (Fixnum) 


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

def completed_tasks
  @completed_tasks
end

#disk_used ⇒ Fixnum

Corresponds to the JSON property diskUsed

Returns:

  • (Fixnum) 


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

def disk_used
  @disk_used
end

#excluded_in_stages ⇒ Array<Fixnum>

Corresponds to the JSON property excludedInStages

Returns:

  • (Array<Fixnum>) 


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

def excluded_in_stages
  @excluded_in_stages
end

#executor_id ⇒ String

Corresponds to the JSON property executorId

Returns:

  • (String) 


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

def executor_id
  @executor_id
end

#executor_logs ⇒ Hash<String,String>

Corresponds to the JSON property executorLogs

Returns:

  • (Hash<String,String>) 


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

def executor_logs
  @executor_logs
end

#failed_tasks ⇒ Fixnum

Corresponds to the JSON property failedTasks

Returns:

  • (Fixnum) 


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

def failed_tasks
  @failed_tasks
end

#host_port ⇒ String

Corresponds to the JSON property hostPort

Returns:

  • (String) 


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

def host_port
  @host_port
end

#is_active ⇒ Boolean Also known as: is_active?

Corresponds to the JSON property isActive

Returns:

  • (Boolean) 


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

def is_active
  @is_active
end

#is_excluded ⇒ Boolean Also known as: is_excluded?

Corresponds to the JSON property isExcluded

Returns:

  • (Boolean) 


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

def is_excluded
  @is_excluded
end

#max_memory ⇒ Fixnum

Corresponds to the JSON property maxMemory

Returns:

  • (Fixnum) 


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

def max_memory
  @max_memory
end

#max_tasks ⇒ Fixnum

Corresponds to the JSON property maxTasks

Returns:

  • (Fixnum) 


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

def max_tasks
  @max_tasks
end

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

Corresponds to the JSON property memoryMetrics

Returns:



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

def memory_metrics
  @memory_metrics
end

#memory_used ⇒ Fixnum

Corresponds to the JSON property memoryUsed

Returns:

  • (Fixnum) 


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

def memory_used
  @memory_used
end

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

Corresponds to the JSON property peakMemoryMetrics

Returns:



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

def peak_memory_metrics
  @peak_memory_metrics
end

#rdd_blocks ⇒ Fixnum

Corresponds to the JSON property rddBlocks

Returns:

  • (Fixnum) 


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

def rdd_blocks
  @rdd_blocks
end

#remove_reason ⇒ String

Corresponds to the JSON property removeReason

Returns:

  • (String) 


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

def remove_reason
  @remove_reason
end

#remove_time ⇒ String

Corresponds to the JSON property removeTime

Returns:

  • (String) 


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

def remove_time
  @remove_time
end

#resource_profile_id ⇒ Fixnum

Corresponds to the JSON property resourceProfileId

Returns:

  • (Fixnum) 


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

def resource_profile_id
  @resource_profile_id
end

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

Corresponds to the JSON property resources

Returns:



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

def resources
  @resources
end

#total_cores ⇒ Fixnum

Corresponds to the JSON property totalCores

Returns:

  • (Fixnum) 


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

def total_cores
  @total_cores
end

#total_duration_millis ⇒ Fixnum

Corresponds to the JSON property totalDurationMillis

Returns:

  • (Fixnum) 


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

def total_duration_millis
  @total_duration_millis
end

#total_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property totalGcTimeMillis

Returns:

  • (Fixnum) 


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

def total_gc_time_millis
  @total_gc_time_millis
end

#total_input_bytes ⇒ Fixnum

Corresponds to the JSON property totalInputBytes

Returns:

  • (Fixnum) 


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

def total_input_bytes
  @total_input_bytes
end

#total_shuffle_read ⇒ Fixnum

Corresponds to the JSON property totalShuffleRead

Returns:

  • (Fixnum) 


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

def total_shuffle_read
  @total_shuffle_read
end

#total_shuffle_write ⇒ Fixnum

Corresponds to the JSON property totalShuffleWrite

Returns:

  • (Fixnum) 


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

def total_shuffle_write
  @total_shuffle_write
end

#total_tasks ⇒ Fixnum

Corresponds to the JSON property totalTasks

Returns:

  • (Fixnum) 


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

def total_tasks
  @total_tasks
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2886
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
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 2886

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