Class: Google::Cloud::Dataflow::V1beta3::StreamingStragglerInfo

Inherits:

Object

• Object
• Google::Cloud::Dataflow::V1beta3::StreamingStragglerInfo

Extended by:

Protobuf::MessageExts::ClassMethods

Includes:

Protobuf::MessageExts

Defined in:

proto_docs/google/dataflow/v1beta3/metrics.rb

Overview

Information useful for streaming straggler identification and debugging.

Instance Attribute Summary

• #data_watermark_lag ⇒ ::Google::Protobuf::Duration

  The event-time watermark lag at the time of the straggler detection.

• #end_time ⇒ ::Google::Protobuf::Timestamp

  End time of this straggler.

• #start_time ⇒ ::Google::Protobuf::Timestamp

  Start time of this straggler.

• #system_watermark_lag ⇒ ::Google::Protobuf::Duration

  The system watermark lag at the time of the straggler detection.

• #worker_name ⇒ ::String

  Name of the worker where the straggler was detected.

Instance Attribute Details

#data_watermark_lag ⇒ ::Google::Protobuf::Duration

Returns The event-time watermark lag at the time of the straggler detection.

Returns:

• (::Google::Protobuf::Duration) —

  The event-time watermark lag at the time of the straggler detection.

# File 'proto_docs/google/dataflow/v1beta3/metrics.rb', line 265

class StreamingStragglerInfo
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#end_time ⇒ ::Google::Protobuf::Timestamp

Returns End time of this straggler.

Returns:

• (::Google::Protobuf::Timestamp) —

  End time of this straggler.

# File 'proto_docs/google/dataflow/v1beta3/metrics.rb', line 265

class StreamingStragglerInfo
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#start_time ⇒ ::Google::Protobuf::Timestamp

Returns Start time of this straggler.

Returns:

• (::Google::Protobuf::Timestamp) —

  Start time of this straggler.

# File 'proto_docs/google/dataflow/v1beta3/metrics.rb', line 265

class StreamingStragglerInfo
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#system_watermark_lag ⇒ ::Google::Protobuf::Duration

Returns The system watermark lag at the time of the straggler detection.

Returns:

• (::Google::Protobuf::Duration) —

  The system watermark lag at the time of the straggler detection.

# File 'proto_docs/google/dataflow/v1beta3/metrics.rb', line 265

class StreamingStragglerInfo
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end

#worker_name ⇒ ::String

Returns Name of the worker where the straggler was detected.

Returns:

• (::String) —

  Name of the worker where the straggler was detected.

# File 'proto_docs/google/dataflow/v1beta3/metrics.rb', line 265

class StreamingStragglerInfo
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods
end