class Google::Apis::DataflowV1b3::ApproximateReportedProgress

A progress measurement of a WorkItem by a worker.

Attributes

consumed_parallelism[RW]

Represents the level of parallelism in a WorkItem's input, reported by the worker. Corresponds to the JSON property `consumedParallelism` @return [Google::Apis::DataflowV1b3::ReportedParallelism]

fraction_consumed[RW]

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` @return [Float]

position[RW]

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` @return [Google::Apis::DataflowV1b3::Position]

remaining_parallelism[RW]

Represents the level of parallelism in a WorkItem's input, reported by the worker. Corresponds to the JSON property `remainingParallelism` @return [Google::Apis::DataflowV1b3::ReportedParallelism]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 87
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 92
def update!(**args)
  @consumed_parallelism = args[:consumed_parallelism] if args.key?(:consumed_parallelism)
  @fraction_consumed = args[:fraction_consumed] if args.key?(:fraction_consumed)
  @position = args[:position] if args.key?(:position)
  @remaining_parallelism = args[:remaining_parallelism] if args.key?(:remaining_parallelism)
end