-
StreamingStragglerInfo.Builder.clear()
The event-time watermark lag at the time of the straggler detection.
End time of this straggler.
Start time of this straggler.
The system watermark lag at the time of the straggler detection.
Name of the worker where the straggler was detected.
Streaming straggler identification and debugging information.
The event-time watermark lag at the time of the straggler detection.
StreamingStragglerInfo.Builder.mergeEndTime(com.google.protobuf.Timestamp value)
End time of this straggler.
StreamingStragglerInfo.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StreamingStragglerInfo.Builder.mergeFrom(com.google.protobuf.Message other)
StreamingStragglerInfo.Builder.mergeStartTime(com.google.protobuf.Timestamp value)
Start time of this straggler.
The system watermark lag at the time of the straggler detection.
StreamingStragglerInfo.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
The event-time watermark lag at the time of the straggler detection.
StreamingStragglerInfo.Builder.setDataWatermarkLag(com.google.protobuf.Duration.Builder builderForValue)
The event-time watermark lag at the time of the straggler detection.
StreamingStragglerInfo.Builder.setEndTime(com.google.protobuf.Timestamp value)
End time of this straggler.
StreamingStragglerInfo.Builder.setEndTime(com.google.protobuf.Timestamp.Builder builderForValue)
End time of this straggler.
StreamingStragglerInfo.Builder.setStartTime(com.google.protobuf.Timestamp value)
Start time of this straggler.
StreamingStragglerInfo.Builder.setStartTime(com.google.protobuf.Timestamp.Builder builderForValue)
Start time of this straggler.
The system watermark lag at the time of the straggler detection.
StreamingStragglerInfo.Builder.setSystemWatermarkLag(com.google.protobuf.Duration.Builder builderForValue)
The system watermark lag at the time of the straggler detection.
Name of the worker where the straggler was detected.
Name of the worker where the straggler was detected.
Streaming straggler identification and debugging information.