Class: Google::Apis::DataprocV1::StateOperatorProgress

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ StateOperatorProgress

Returns a new instance of StateOperatorProgress.



10019
10020
10021
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10019

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

Instance Attribute Details

#all_removals_time_ms ⇒ Fixnum

Corresponds to the JSON property allRemovalsTimeMs

Returns:

  • (Fixnum) 


9962
9963
9964
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9962

def all_removals_time_ms
  @all_removals_time_ms
end

#all_updates_time_ms ⇒ Fixnum

Corresponds to the JSON property allUpdatesTimeMs

Returns:

  • (Fixnum) 


9967
9968
9969
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9967

def all_updates_time_ms
  @all_updates_time_ms
end

#commit_time_ms ⇒ Fixnum

Corresponds to the JSON property commitTimeMs

Returns:

  • (Fixnum) 


9972
9973
9974
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9972

def commit_time_ms
  @commit_time_ms
end

#custom_metrics ⇒ Hash<String,Fixnum>

Corresponds to the JSON property customMetrics

Returns:

  • (Hash<String,Fixnum>) 


9977
9978
9979
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9977

def custom_metrics
  @custom_metrics
end

#memory_used_bytes ⇒ Fixnum

Corresponds to the JSON property memoryUsedBytes

Returns:

  • (Fixnum) 


9982
9983
9984
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9982

def memory_used_bytes
  @memory_used_bytes
end

#num_rows_dropped_by_watermark ⇒ Fixnum

Corresponds to the JSON property numRowsDroppedByWatermark

Returns:

  • (Fixnum) 


9987
9988
9989
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9987

def num_rows_dropped_by_watermark
  @num_rows_dropped_by_watermark
end

#num_rows_removed ⇒ Fixnum

Corresponds to the JSON property numRowsRemoved

Returns:

  • (Fixnum) 


9992
9993
9994
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9992

def num_rows_removed
  @num_rows_removed
end

#num_rows_total ⇒ Fixnum

Corresponds to the JSON property numRowsTotal

Returns:

  • (Fixnum) 


9997
9998
9999
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 9997

def num_rows_total
  @num_rows_total
end

#num_rows_updated ⇒ Fixnum

Corresponds to the JSON property numRowsUpdated

Returns:

  • (Fixnum) 


10002
10003
10004
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10002

def num_rows_updated
  @num_rows_updated
end

#num_shuffle_partitions ⇒ Fixnum

Corresponds to the JSON property numShufflePartitions

Returns:

  • (Fixnum) 


10007
10008
10009
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10007

def num_shuffle_partitions
  @num_shuffle_partitions
end

#num_state_store_instances ⇒ Fixnum

Corresponds to the JSON property numStateStoreInstances

Returns:

  • (Fixnum) 


10012
10013
10014
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10012

def num_state_store_instances
  @num_state_store_instances
end

#operator_name ⇒ String

Corresponds to the JSON property operatorName

Returns:

  • (String) 


10017
10018
10019
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10017

def operator_name
  @operator_name
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



10024
10025
10026
10027
10028
10029
10030
10031
10032
10033
10034
10035
10036
10037
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10024

def update!(**args)
  @all_removals_time_ms = args[:all_removals_time_ms] if args.key?(:all_removals_time_ms)
  @all_updates_time_ms = args[:all_updates_time_ms] if args.key?(:all_updates_time_ms)
  @commit_time_ms = args[:commit_time_ms] if args.key?(:commit_time_ms)
  @custom_metrics = args[:custom_metrics] if args.key?(:custom_metrics)
  @memory_used_bytes = args[:memory_used_bytes] if args.key?(:memory_used_bytes)
  @num_rows_dropped_by_watermark = args[:num_rows_dropped_by_watermark] if args.key?(:num_rows_dropped_by_watermark)
  @num_rows_removed = args[:num_rows_removed] if args.key?(:num_rows_removed)
  @num_rows_total = args[:num_rows_total] if args.key?(:num_rows_total)
  @num_rows_updated = args[:num_rows_updated] if args.key?(:num_rows_updated)
  @num_shuffle_partitions = args[:num_shuffle_partitions] if args.key?(:num_shuffle_partitions)
  @num_state_store_instances = args[:num_state_store_instances] if args.key?(:num_state_store_instances)
  @operator_name = args[:operator_name] if args.key?(:operator_name)
end