Class: Google::Apis::DataflowV1b3::CounterStructuredName
- Inherits:
 - 
      Object
      
        
- Object
 - Google::Apis::DataflowV1b3::CounterStructuredName
 
 
- 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
Identifies a counter within a per-job namespace. Counters whose structured names are the same get merged into a single value for the job.
Instance Attribute Summary collapse
- 
  
    
      #component_step_name  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
Name of the optimized step being executed by the workers.
 - 
  
    
      #execution_step_name  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
Name of the stage.
 - 
  
    
      #input_index  ⇒ Fixnum 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
Index of an input collection that's being read from/written to as a side input.
 - 
  
    
      #name  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
Counter name.
 - 
  
    
      #origin  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
One of the standard Origins defined above.
 - 
  
    
      #origin_namespace  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
A string containing a more specific namespace of the counter's origin.
 - 
  
    
      #original_requesting_step_name  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
The step name requesting an operation, such as GBK.
 - 
  
    
      #original_step_name  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
System generated name of the original step in the user's graph, before optimization.
 - 
  
    
      #portion  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
Portion of this counter, either key or value.
 - 
  
    
      #worker_id  ⇒ String 
    
    
  
  
  
  
    
    
  
  
  
  
  
  
    
ID of a particular worker.
 
Instance Method Summary collapse
- 
  
    
      #initialize(**args)  ⇒ CounterStructuredName 
    
    
  
  
  
    constructor
  
  
  
  
  
  
  
    
A new instance of CounterStructuredName.
 - 
  
    
      #update!(**args)  ⇒ Object 
    
    
  
  
  
  
  
  
  
  
  
    
Update properties of this object.
 
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ CounterStructuredName
Returns a new instance of CounterStructuredName
      553 554 555  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 553 def initialize(**args) update!(**args) end  | 
  
Instance Attribute Details
#component_step_name ⇒ String
Name of the optimized step being executed by the workers.
Corresponds to the JSON property componentStepName
      496 497 498  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 496 def component_step_name @component_step_name end  | 
  
#execution_step_name ⇒ String
Name of the stage. An execution step contains multiple component steps.
Corresponds to the JSON property executionStepName
      501 502 503  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 501 def execution_step_name @execution_step_name end  | 
  
#input_index ⇒ Fixnum
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
      511 512 513  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 511 def input_index @input_index end  | 
  
#name ⇒ String
Counter name. Not necessarily globally-unique, but unique within the
context of the other fields.
Required.
Corresponds to the JSON property name
      518 519 520  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 518 def name @name end  | 
  
#origin ⇒ String
One of the standard Origins defined above.
Corresponds to the JSON property origin
      523 524 525  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 523 def origin @origin end  | 
  
#origin_namespace ⇒ String
A string containing a more specific namespace of the counter's origin.
Corresponds to the JSON property originNamespace
      528 529 530  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 528 def origin_namespace @origin_namespace end  | 
  
#original_requesting_step_name ⇒ 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
      535 536 537  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 535 def original_requesting_step_name @original_requesting_step_name end  | 
  
#original_step_name ⇒ String
System generated name of the original step in the user's graph, before
optimization.
Corresponds to the JSON property originalStepName
      541 542 543  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 541 def original_step_name @original_step_name end  | 
  
#portion ⇒ String
Portion of this counter, either key or value.
Corresponds to the JSON property portion
      546 547 548  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 546 def portion @portion end  | 
  
#worker_id ⇒ String
ID of a particular worker.
Corresponds to the JSON property workerId
      551 552 553  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 551 def worker_id @worker_id end  | 
  
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
      558 559 560 561 562 563 564 565 566 567 568 569  | 
    
      # File 'generated/google/apis/dataflow_v1b3/classes.rb', line 558 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  |