Class: Google::Apis::DataflowV1b3::ApproximateReportedProgress

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb

Overview

A progress measurement of a WorkItem by a worker.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

Constructor Details

#initialize(**args) ⇒ ApproximateReportedProgress


1784
1785
1786
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 1784

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

Instance Attribute Details

#consumed_parallelismGoogle::Apis::DataflowV1b3::ReportedParallelism

Represents the level of parallelism in a WorkItem's input, reported by the worker. Corresponds to the JSON property consumedParallelism


1782
1783
1784
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 1782

def consumed_parallelism
  @consumed_parallelism
end

#fraction_consumedFloat

Completion as fraction of the input consumed, from 0.0 (beginning, nothing consumed), to 1.0 (end of the input, entire input consumed). Corresponds to the JSON property fractionConsumed


1770
1771
1772
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 1770

def fraction_consumed
  @fraction_consumed
end

#positionGoogle::Apis::DataflowV1b3::Position

Position defines a position within a collection of data. The value can be either the end position, a key (used with ordered collections), a byte offset, or a record index. Corresponds to the JSON property position


1764
1765
1766
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 1764

def position
  @position
end

#remaining_parallelismGoogle::Apis::DataflowV1b3::ReportedParallelism

Represents the level of parallelism in a WorkItem's input, reported by the worker. Corresponds to the JSON property remainingParallelism


1776
1777
1778
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 1776

def remaining_parallelism
  @remaining_parallelism
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object


1789
1790
1791
1792
1793
1794
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 1789

def update!(**args)
  @position = args[:position] if args.key?(:position)
  @fraction_consumed = args[:fraction_consumed] if args.key?(:fraction_consumed)
  @remaining_parallelism = args[:remaining_parallelism] if args.key?(:remaining_parallelism)
  @consumed_parallelism = args[:consumed_parallelism] if args.key?(:consumed_parallelism)
end