Send feedback
Class StreamingStragglerInfo (0.80.0)
Stay organized with collections
Save and categorize content based on your preferences.
public final class StreamingStragglerInfo extends GeneratedMessageV3 implements StreamingStragglerInfoOrBuilder
Information useful for streaming straggler identification and debugging.
Protobuf type google.dataflow.v1beta3.StreamingStragglerInfo
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
DATA_WATERMARK_LAG_FIELD_NUMBER
public static final int DATA_WATERMARK_LAG_FIELD_NUMBER
Field Value
Type Description
int
END_TIME_FIELD_NUMBER
public static final int END_TIME_FIELD_NUMBER
Field Value
Type Description
int
START_TIME_FIELD_NUMBER
public static final int START_TIME_FIELD_NUMBER
Field Value
Type Description
int
SYSTEM_WATERMARK_LAG_FIELD_NUMBER
public static final int SYSTEM_WATERMARK_LAG_FIELD_NUMBER
Field Value
Type Description
int
WORKER_NAME_FIELD_NUMBER
public static final int WORKER_NAME_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static StreamingStragglerInfo getDefaultInstance ()
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static StreamingStragglerInfo . Builder newBuilder ()
newBuilder(StreamingStragglerInfo prototype)
public static StreamingStragglerInfo . Builder newBuilder ( StreamingStragglerInfo prototype )
public static StreamingStragglerInfo parseDelimitedFrom ( InputStream input )
public static StreamingStragglerInfo parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(byte[] data)
public static StreamingStragglerInfo parseFrom ( byte [] data )
Parameter
Name Description
databyte []
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static StreamingStragglerInfo parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteString data)
public static StreamingStragglerInfo parseFrom ( ByteString data )
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static StreamingStragglerInfo parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
public static StreamingStragglerInfo parseFrom ( CodedInputStream input )
public static StreamingStragglerInfo parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
public static StreamingStragglerInfo parseFrom ( InputStream input )
public static StreamingStragglerInfo parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteBuffer data)
public static StreamingStragglerInfo parseFrom ( ByteBuffer data )
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static StreamingStragglerInfo parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
parser()
public static Parser<StreamingStragglerInfo> parser ()
Methods
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getDataWatermarkLag()
public Duration getDataWatermarkLag ()
The event-time watermark lag at the time of the straggler detection.
.google.protobuf.Duration data_watermark_lag = 4;
Returns
Type Description
Duration The dataWatermarkLag.
getDataWatermarkLagOrBuilder()
public DurationOrBuilder getDataWatermarkLagOrBuilder ()
The event-time watermark lag at the time of the straggler detection.
.google.protobuf.Duration data_watermark_lag = 4;
getDefaultInstanceForType()
public StreamingStragglerInfo getDefaultInstanceForType ()
getEndTime()
public Timestamp getEndTime ()
End time of this straggler.
.google.protobuf.Timestamp end_time = 2;
Returns
Type Description
Timestamp The endTime.
getEndTimeOrBuilder()
public TimestampOrBuilder getEndTimeOrBuilder ()
End time of this straggler.
.google.protobuf.Timestamp end_time = 2;
getParserForType()
public Parser<StreamingStragglerInfo> getParserForType ()
Overrides
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
Overrides
getStartTime()
public Timestamp getStartTime ()
Start time of this straggler.
.google.protobuf.Timestamp start_time = 1;
Returns
Type Description
Timestamp The startTime.
getStartTimeOrBuilder()
public TimestampOrBuilder getStartTimeOrBuilder ()
Start time of this straggler.
.google.protobuf.Timestamp start_time = 1;
getSystemWatermarkLag()
public Duration getSystemWatermarkLag ()
The system watermark lag at the time of the straggler detection.
.google.protobuf.Duration system_watermark_lag = 5;
Returns
Type Description
Duration The systemWatermarkLag.
getSystemWatermarkLagOrBuilder()
public DurationOrBuilder getSystemWatermarkLagOrBuilder ()
The system watermark lag at the time of the straggler detection.
.google.protobuf.Duration system_watermark_lag = 5;
getWorkerName()
public String getWorkerName ()
Name of the worker where the straggler was detected.
string worker_name = 3;
Returns
Type Description
String The workerName.
getWorkerNameBytes()
public ByteString getWorkerNameBytes ()
Name of the worker where the straggler was detected.
string worker_name = 3;
Returns
Type Description
ByteString The bytes for workerName.
hasDataWatermarkLag()
public boolean hasDataWatermarkLag ()
The event-time watermark lag at the time of the straggler detection.
.google.protobuf.Duration data_watermark_lag = 4;
Returns
Type Description
boolean Whether the dataWatermarkLag field is set.
hasEndTime()
public boolean hasEndTime ()
End time of this straggler.
.google.protobuf.Timestamp end_time = 2;
Returns
Type Description
boolean Whether the endTime field is set.
hasStartTime()
public boolean hasStartTime ()
Start time of this straggler.
.google.protobuf.Timestamp start_time = 1;
Returns
Type Description
boolean Whether the startTime field is set.
hasSystemWatermarkLag()
public boolean hasSystemWatermarkLag ()
The system watermark lag at the time of the straggler detection.
.google.protobuf.Duration system_watermark_lag = 5;
Returns
Type Description
boolean Whether the systemWatermarkLag field is set.
hashCode()
Returns
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public StreamingStragglerInfo . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected StreamingStragglerInfo . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public StreamingStragglerInfo . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-10-11 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-10-11 UTC."],[],[]]
