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.



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

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

Instance Attribute Details

#active_tasks ⇒ Fixnum

Corresponds to the JSON property activeTasks

Returns:

  • (Fixnum) 


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

def active_tasks
  @active_tasks
end

#add_time ⇒ String

Corresponds to the JSON property addTime

Returns:

  • (String) 


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

def add_time
  @add_time
end

#attributes ⇒ Hash<String,String>

Corresponds to the JSON property attributes

Returns:

  • (Hash<String,String>) 


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

def attributes
  @attributes
end

#completed_tasks ⇒ Fixnum

Corresponds to the JSON property completedTasks

Returns:

  • (Fixnum) 


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

def completed_tasks
  @completed_tasks
end

#disk_used ⇒ Fixnum

Corresponds to the JSON property diskUsed

Returns:

  • (Fixnum) 


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

def disk_used
  @disk_used
end

#excluded_in_stages ⇒ Array<Fixnum>

Corresponds to the JSON property excludedInStages

Returns:

  • (Array<Fixnum>) 


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

def excluded_in_stages
  @excluded_in_stages
end

#executor_id ⇒ String

Corresponds to the JSON property executorId

Returns:

  • (String) 


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

def executor_id
  @executor_id
end

#executor_logs ⇒ Hash<String,String>

Corresponds to the JSON property executorLogs

Returns:

  • (Hash<String,String>) 


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

def executor_logs
  @executor_logs
end

#failed_tasks ⇒ Fixnum

Corresponds to the JSON property failedTasks

Returns:

  • (Fixnum) 


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

def failed_tasks
  @failed_tasks
end

#host_port ⇒ String

Corresponds to the JSON property hostPort

Returns:

  • (String) 


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

def host_port
  @host_port
end

#is_active ⇒ Boolean Also known as: is_active?

Corresponds to the JSON property isActive

Returns:

  • (Boolean) 


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

def is_active
  @is_active
end

#is_excluded ⇒ Boolean Also known as: is_excluded?

Corresponds to the JSON property isExcluded

Returns:

  • (Boolean) 


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

def is_excluded
  @is_excluded
end

#max_memory ⇒ Fixnum

Corresponds to the JSON property maxMemory

Returns:

  • (Fixnum) 


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

def max_memory
  @max_memory
end

#max_tasks ⇒ Fixnum

Corresponds to the JSON property maxTasks

Returns:

  • (Fixnum) 


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

def max_tasks
  @max_tasks
end

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

Corresponds to the JSON property memoryMetrics

Returns:



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

def memory_metrics
  @memory_metrics
end

#memory_used ⇒ Fixnum

Corresponds to the JSON property memoryUsed

Returns:

  • (Fixnum) 


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

def memory_used
  @memory_used
end

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

Corresponds to the JSON property peakMemoryMetrics

Returns:



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

def peak_memory_metrics
  @peak_memory_metrics
end

#rdd_blocks ⇒ Fixnum

Corresponds to the JSON property rddBlocks

Returns:

  • (Fixnum) 


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

def rdd_blocks
  @rdd_blocks
end

#remove_reason ⇒ String

Corresponds to the JSON property removeReason

Returns:

  • (String) 


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

def remove_reason
  @remove_reason
end

#remove_time ⇒ String

Corresponds to the JSON property removeTime

Returns:

  • (String) 


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

def remove_time
  @remove_time
end

#resource_profile_id ⇒ Fixnum

Corresponds to the JSON property resourceProfileId

Returns:

  • (Fixnum) 


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

def resource_profile_id
  @resource_profile_id
end

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

Corresponds to the JSON property resources

Returns:



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

def resources
  @resources
end

#total_cores ⇒ Fixnum

Corresponds to the JSON property totalCores

Returns:

  • (Fixnum) 


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

def total_cores
  @total_cores
end

#total_duration_millis ⇒ Fixnum

Corresponds to the JSON property totalDurationMillis

Returns:

  • (Fixnum) 


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

def total_duration_millis
  @total_duration_millis
end

#total_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property totalGcTimeMillis

Returns:

  • (Fixnum) 


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

def total_gc_time_millis
  @total_gc_time_millis
end

#total_input_bytes ⇒ Fixnum

Corresponds to the JSON property totalInputBytes

Returns:

  • (Fixnum) 


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

def total_input_bytes
  @total_input_bytes
end

#total_shuffle_read ⇒ Fixnum

Corresponds to the JSON property totalShuffleRead

Returns:

  • (Fixnum) 


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

def total_shuffle_read
  @total_shuffle_read
end

#total_shuffle_write ⇒ Fixnum

Corresponds to the JSON property totalShuffleWrite

Returns:

  • (Fixnum) 


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

def total_shuffle_write
  @total_shuffle_write
end

#total_tasks ⇒ Fixnum

Corresponds to the JSON property totalTasks

Returns:

  • (Fixnum) 


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

def total_tasks
  @total_tasks
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



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

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