Dataflow v1beta3 API - Class StreamingStragglerInfo (2.0.0-beta09) 

public sealed class StreamingStragglerInfo : IMessage<StreamingStragglerInfo>, IEquatable<StreamingStragglerInfo>, IDeepCloneable<StreamingStragglerInfo>, IBufferMessage, IMessage

Reference documentation and code samples for the Dataflow v1beta3 API class StreamingStragglerInfo.

Information useful for streaming straggler identification and debugging.

Inheritance

object > StreamingStragglerInfo

Namespace

Google.Cloud.Dataflow.V1Beta3

Assembly

Google.Cloud.Dataflow.V1Beta3.dll

Constructors

StreamingStragglerInfo()

public StreamingStragglerInfo()

StreamingStragglerInfo(StreamingStragglerInfo)

public StreamingStragglerInfo(StreamingStragglerInfo other)
Parameter
Name Description
other StreamingStragglerInfo

Properties

DataWatermarkLag

public Duration DataWatermarkLag { get; set; }

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

Property Value
Type Description
Duration

EndTime

public Timestamp EndTime { get; set; }

End time of this straggler.

Property Value
Type Description
Timestamp

StartTime

public Timestamp StartTime { get; set; }

Start time of this straggler.

Property Value
Type Description
Timestamp

SystemWatermarkLag

public Duration SystemWatermarkLag { get; set; }

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

Property Value
Type Description
Duration

WorkerName

public string WorkerName { get; set; }

Name of the worker where the straggler was detected.

Property Value
Type Description
string