Class: Google::Apis::DataprocV1::TaskMetrics

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

Executor Task Metrics

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ TaskMetrics

Returns a new instance of TaskMetrics.



11377
11378
11379
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11377

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

Instance Attribute Details

#disk_bytes_spilled ⇒ Fixnum

Corresponds to the JSON property diskBytesSpilled

Returns:

  • (Fixnum) 


11310
11311
11312
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11310

def disk_bytes_spilled
  @disk_bytes_spilled
end

#executor_cpu_time_nanos ⇒ Fixnum

Corresponds to the JSON property executorCpuTimeNanos

Returns:

  • (Fixnum) 


11315
11316
11317
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11315

def executor_cpu_time_nanos
  @executor_cpu_time_nanos
end

#executor_deserialize_cpu_time_nanos ⇒ Fixnum

Corresponds to the JSON property executorDeserializeCpuTimeNanos

Returns:

  • (Fixnum) 


11320
11321
11322
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11320

def executor_deserialize_cpu_time_nanos
  @executor_deserialize_cpu_time_nanos
end

#executor_deserialize_time_millis ⇒ Fixnum

Corresponds to the JSON property executorDeserializeTimeMillis

Returns:

  • (Fixnum) 


11325
11326
11327
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11325

def executor_deserialize_time_millis
  @executor_deserialize_time_millis
end

#executor_run_time_millis ⇒ Fixnum

Corresponds to the JSON property executorRunTimeMillis

Returns:

  • (Fixnum) 


11330
11331
11332
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11330

def executor_run_time_millis
  @executor_run_time_millis
end

#input_metrics ⇒ Google::Apis::DataprocV1::InputMetrics

Metrics about the input data read by the task. Corresponds to the JSON property inputMetrics

Returns:



11335
11336
11337
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11335

def input_metrics
  @input_metrics
end

#jvm_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property jvmGcTimeMillis

Returns:

  • (Fixnum) 


11340
11341
11342
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11340

def jvm_gc_time_millis
  @jvm_gc_time_millis
end

#memory_bytes_spilled ⇒ Fixnum

Corresponds to the JSON property memoryBytesSpilled

Returns:

  • (Fixnum) 


11345
11346
11347
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11345

def memory_bytes_spilled
  @memory_bytes_spilled
end

#output_metrics ⇒ Google::Apis::DataprocV1::OutputMetrics

Metrics about the data written by the task. Corresponds to the JSON property outputMetrics

Returns:



11350
11351
11352
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11350

def output_metrics
  @output_metrics
end

#peak_execution_memory_bytes ⇒ Fixnum

Corresponds to the JSON property peakExecutionMemoryBytes

Returns:

  • (Fixnum) 


11355
11356
11357
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11355

def peak_execution_memory_bytes
  @peak_execution_memory_bytes
end

#result_serialization_time_millis ⇒ Fixnum

Corresponds to the JSON property resultSerializationTimeMillis

Returns:

  • (Fixnum) 


11360
11361
11362
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11360

def result_serialization_time_millis
  @result_serialization_time_millis
end

#result_size ⇒ Fixnum

Corresponds to the JSON property resultSize

Returns:

  • (Fixnum) 


11365
11366
11367
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11365

def result_size
  @result_size
end

#shuffle_read_metrics ⇒ Google::Apis::DataprocV1::ShuffleReadMetrics

Shuffle data read by the task. Corresponds to the JSON property shuffleReadMetrics

Returns:



11370
11371
11372
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11370

def shuffle_read_metrics
  @shuffle_read_metrics
end

#shuffle_write_metrics ⇒ Google::Apis::DataprocV1::ShuffleWriteMetrics

Shuffle data written by task. Corresponds to the JSON property shuffleWriteMetrics

Returns:



11375
11376
11377
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11375

def shuffle_write_metrics
  @shuffle_write_metrics
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



11382
11383
11384
11385
11386
11387
11388
11389
11390
11391
11392
11393
11394
11395
11396
11397
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 11382

def update!(**args)
  @disk_bytes_spilled = args[:disk_bytes_spilled] if args.key?(:disk_bytes_spilled)
  @executor_cpu_time_nanos = args[:executor_cpu_time_nanos] if args.key?(:executor_cpu_time_nanos)
  @executor_deserialize_cpu_time_nanos = args[:executor_deserialize_cpu_time_nanos] if args.key?(:executor_deserialize_cpu_time_nanos)
  @executor_deserialize_time_millis = args[:executor_deserialize_time_millis] if args.key?(:executor_deserialize_time_millis)
  @executor_run_time_millis = args[:executor_run_time_millis] if args.key?(:executor_run_time_millis)
  @input_metrics = args[:input_metrics] if args.key?(:input_metrics)
  @jvm_gc_time_millis = args[:jvm_gc_time_millis] if args.key?(:jvm_gc_time_millis)
  @memory_bytes_spilled = args[:memory_bytes_spilled] if args.key?(:memory_bytes_spilled)
  @output_metrics = args[:output_metrics] if args.key?(:output_metrics)
  @peak_execution_memory_bytes = args[:peak_execution_memory_bytes] if args.key?(:peak_execution_memory_bytes)
  @result_serialization_time_millis = args[:result_serialization_time_millis] if args.key?(:result_serialization_time_millis)
  @result_size = args[:result_size] if args.key?(:result_size)
  @shuffle_read_metrics = args[:shuffle_read_metrics] if args.key?(:shuffle_read_metrics)
  @shuffle_write_metrics = args[:shuffle_write_metrics] if args.key?(:shuffle_write_metrics)
end