class Google::Apis::DataflowV1b3::CounterStructuredName
Identifies a counter within a per-job namespace. Counters whose structured names are the same get merged into a single value for the job.
Attributes
Name of the optimized step being executed by the workers. Corresponds to the JSON property `componentStepName` @return [String]
Name of the stage. An execution step contains multiple component steps. Corresponds to the JSON property `executionStepName` @return [String]
Index of an input collection that's being read from/written to as a side input. The index identifies a step's side inputs starting by 1 (e.g. the first side input has input_index
1, the third has input_index
3). Side inputs are identified by a pair of (original_step_name
, input_index
). This field helps uniquely identify them. Corresponds to the JSON property `inputIndex` @return [Fixnum]
Counter name. Not necessarily globally-unique, but unique within the context of the other fields. Required. Corresponds to the JSON property `name` @return [String]
One of the standard Origins defined above. Corresponds to the JSON property `origin` @return [String]
A string containing a more specific namespace of the counter's origin. Corresponds to the JSON property `originNamespace` @return [String]
The step name requesting an operation, such as GBK. I.e. the ParDo causing a read/write from shuffle to occur, or a read from side inputs. Corresponds to the JSON property `originalRequestingStepName` @return [String]
System generated name of the original step in the user's graph, before optimization. Corresponds to the JSON property `originalStepName` @return [String]
Portion of this counter, either key or value. Corresponds to the JSON property `portion` @return [String]
ID of a particular worker. Corresponds to the JSON property `workerId` @return [String]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 591 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 596 def update!(**args) @component_step_name = args[:component_step_name] if args.key?(:component_step_name) @execution_step_name = args[:execution_step_name] if args.key?(:execution_step_name) @input_index = args[:input_index] if args.key?(:input_index) @name = args[:name] if args.key?(:name) @origin = args[:origin] if args.key?(:origin) @origin_namespace = args[:origin_namespace] if args.key?(:origin_namespace) @original_requesting_step_name = args[:original_requesting_step_name] if args.key?(:original_requesting_step_name) @original_step_name = args[:original_step_name] if args.key?(:original_step_name) @portion = args[:portion] if args.key?(:portion) @worker_id = args[:worker_id] if args.key?(:worker_id) end