Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::StreamingStragglerInfo.
Information useful for streaming straggler identification and debugging.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#data_watermark_lag
def data_watermark_lag() -> ::Google::Protobuf::Duration Returns
- (::Google::Protobuf::Duration) — The event-time watermark lag at the time of the straggler detection.
#data_watermark_lag=
def data_watermark_lag=(value) -> ::Google::Protobuf::Duration Parameter
- value (::Google::Protobuf::Duration) — 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.
#end_time
def end_time() -> ::Google::Protobuf::Timestamp Returns
- (::Google::Protobuf::Timestamp) — End time of this straggler.
#end_time=
def end_time=(value) -> ::Google::Protobuf::Timestamp Parameter
- value (::Google::Protobuf::Timestamp) — End time of this straggler.
Returns
- (::Google::Protobuf::Timestamp) — End time of this straggler.
#start_time
def start_time() -> ::Google::Protobuf::Timestamp Returns
- (::Google::Protobuf::Timestamp) — Start time of this straggler.
#start_time=
def start_time=(value) -> ::Google::Protobuf::Timestamp Parameter
- value (::Google::Protobuf::Timestamp) — Start time of this straggler.
Returns
- (::Google::Protobuf::Timestamp) — Start time of this straggler.
#system_watermark_lag
def system_watermark_lag() -> ::Google::Protobuf::Duration Returns
- (::Google::Protobuf::Duration) — The system watermark lag at the time of the straggler detection.
#system_watermark_lag=
def system_watermark_lag=(value) -> ::Google::Protobuf::Duration Parameter
- value (::Google::Protobuf::Duration) — 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.
#worker_name
def worker_name() -> ::String Returns
- (::String) — Name of the worker where the straggler was detected.
#worker_name=
def worker_name=(value) -> ::String Parameter
- value (::String) — Name of the worker where the straggler was detected.
Returns
- (::String) — Name of the worker where the straggler was detected.