Class: Google::Apis::DataprocV1::StageMetrics

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

Stage Level Aggregated Metrics

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ StageMetrics

Returns a new instance of StageMetrics.



9597
9598
9599
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9597

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

Instance Attribute Details

#disk_bytes_spilled ⇒ Fixnum

Corresponds to the JSON property diskBytesSpilled

Returns:

  • (Fixnum) 


9530
9531
9532
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9530

def disk_bytes_spilled
  @disk_bytes_spilled
end

#executor_cpu_time_nanos ⇒ Fixnum

Corresponds to the JSON property executorCpuTimeNanos

Returns:

  • (Fixnum) 


9535
9536
9537
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9535

def executor_cpu_time_nanos
  @executor_cpu_time_nanos
end

#executor_deserialize_cpu_time_nanos ⇒ Fixnum

Corresponds to the JSON property executorDeserializeCpuTimeNanos

Returns:

  • (Fixnum) 


9540
9541
9542
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9540

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) 


9545
9546
9547
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9545

def executor_deserialize_time_millis
  @executor_deserialize_time_millis
end

#executor_run_time_millis ⇒ Fixnum

Corresponds to the JSON property executorRunTimeMillis

Returns:

  • (Fixnum) 


9550
9551
9552
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9550

def executor_run_time_millis
  @executor_run_time_millis
end

#jvm_gc_time_millis ⇒ Fixnum

Corresponds to the JSON property jvmGcTimeMillis

Returns:

  • (Fixnum) 


9555
9556
9557
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9555

def jvm_gc_time_millis
  @jvm_gc_time_millis
end

#memory_bytes_spilled ⇒ Fixnum

Corresponds to the JSON property memoryBytesSpilled

Returns:

  • (Fixnum) 


9560
9561
9562
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9560

def memory_bytes_spilled
  @memory_bytes_spilled
end

#peak_execution_memory_bytes ⇒ Fixnum

Corresponds to the JSON property peakExecutionMemoryBytes

Returns:

  • (Fixnum) 


9565
9566
9567
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9565

def peak_execution_memory_bytes
  @peak_execution_memory_bytes
end

#result_serialization_time_millis ⇒ Fixnum

Corresponds to the JSON property resultSerializationTimeMillis

Returns:

  • (Fixnum) 


9570
9571
9572
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9570

def result_serialization_time_millis
  @result_serialization_time_millis
end

#result_size ⇒ Fixnum

Corresponds to the JSON property resultSize

Returns:

  • (Fixnum) 


9575
9576
9577
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9575

def result_size
  @result_size
end

#stage_input_metrics ⇒ Google::Apis::DataprocV1::StageInputMetrics

Metrics about the input read by the stage. Corresponds to the JSON property stageInputMetrics

Returns:



9580
9581
9582
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9580

def stage_input_metrics
  @stage_input_metrics
end

#stage_output_metrics ⇒ Google::Apis::DataprocV1::StageOutputMetrics

Metrics about the output written by the stage. Corresponds to the JSON property stageOutputMetrics

Returns:



9585
9586
9587
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9585

def stage_output_metrics
  @stage_output_metrics
end

#stage_shuffle_read_metrics ⇒ Google::Apis::DataprocV1::StageShuffleReadMetrics

Shuffle data read for the stage. Corresponds to the JSON property stageShuffleReadMetrics

Returns:



9590
9591
9592
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9590

def stage_shuffle_read_metrics
  @stage_shuffle_read_metrics
end

#stage_shuffle_write_metrics ⇒ Google::Apis::DataprocV1::StageShuffleWriteMetrics

Shuffle data written for the stage. Corresponds to the JSON property stageShuffleWriteMetrics

Returns:



9595
9596
9597
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9595

def stage_shuffle_write_metrics
  @stage_shuffle_write_metrics
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



9602
9603
9604
9605
9606
9607
9608
9609
9610
9611
9612
9613
9614
9615
9616
9617
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9602

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)
  @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)
  @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)
  @stage_input_metrics = args[:stage_input_metrics] if args.key?(:stage_input_metrics)
  @stage_output_metrics = args[:stage_output_metrics] if args.key?(:stage_output_metrics)
  @stage_shuffle_read_metrics = args[:stage_shuffle_read_metrics] if args.key?(:stage_shuffle_read_metrics)
  @stage_shuffle_write_metrics = args[:stage_shuffle_write_metrics] if args.key?(:stage_shuffle_write_metrics)
end