Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::StreamingStragglerInfo (v0.13.0)

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

#data_watermark_lag=

def data_watermark_lag=(value) -> ::Google::Protobuf::Duration
Parameter
Returns

#end_time

def end_time() -> ::Google::Protobuf::Timestamp
Returns

#end_time=

def end_time=(value) -> ::Google::Protobuf::Timestamp
Parameter
Returns

#start_time

def start_time() -> ::Google::Protobuf::Timestamp
Returns

#start_time=

def start_time=(value) -> ::Google::Protobuf::Timestamp
Parameter
Returns

#system_watermark_lag

def system_watermark_lag() -> ::Google::Protobuf::Duration
Returns

#system_watermark_lag=

def system_watermark_lag=(value) -> ::Google::Protobuf::Duration
Parameter
Returns

#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.