Class: Google::Apis::DataflowV1b3::StreamingStragglerInfo

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

Overview

Information useful for streaming straggler identification and debugging.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ StreamingStragglerInfo

Returns a new instance of StreamingStragglerInfo.



6631
6632
6633
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6631

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

Instance Attribute Details

#data_watermark_lag ⇒ String

The event-time watermark lag at the time of the straggler detection. Corresponds to the JSON property dataWatermarkLag

Returns:

  • (String) 


6609
6610
6611
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6609

def data_watermark_lag
  @data_watermark_lag
end

#end_time ⇒ String

End time of this straggler. Corresponds to the JSON property endTime

Returns:

  • (String) 


6614
6615
6616
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6614

def end_time
  @end_time
end

#start_time ⇒ String

Start time of this straggler. Corresponds to the JSON property startTime

Returns:

  • (String) 


6619
6620
6621
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6619

def start_time
  @start_time
end

#system_watermark_lag ⇒ String

The system watermark lag at the time of the straggler detection. Corresponds to the JSON property systemWatermarkLag

Returns:

  • (String) 


6624
6625
6626
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6624

def system_watermark_lag
  @system_watermark_lag
end

#worker_name ⇒ String

Name of the worker where the straggler was detected. Corresponds to the JSON property workerName

Returns:

  • (String) 


6629
6630
6631
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6629

def worker_name
  @worker_name
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



6636
6637
6638
6639
6640
6641
6642
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6636

def update!(**args)
  @data_watermark_lag = args[:data_watermark_lag] if args.key?(:data_watermark_lag)
  @end_time = args[:end_time] if args.key?(:end_time)
  @start_time = args[:start_time] if args.key?(:start_time)
  @system_watermark_lag = args[:system_watermark_lag] if args.key?(:system_watermark_lag)
  @worker_name = args[:worker_name] if args.key?(:worker_name)
end