class Google::Apis::DataflowV1b3::WorkItemServiceState
The Dataflow service's idea of the current state of a WorkItem
being processed by a worker.
Attributes
The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [ gRPC](github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https: //cloud.google.com/apis/design/errors). Corresponds to the JSON property `completeWorkStatus` @return [Google::Apis::DataflowV1b3::Status]
Other data returned by the service, specific to the particular worker harness. Corresponds to the JSON property `harnessData` @return [Hash<String,Object>]
Proto describing a hot key detected on a given WorkItem
. Corresponds to the JSON property `hotKeyDetection` @return [Google::Apis::DataflowV1b3::HotKeyDetection]
Time at which the current lease will expire. Corresponds to the JSON property `leaseExpireTime` @return [String]
The short ids that workers should use in subsequent metric updates. Workers should strive to use short ids whenever possible, but it is ok to request the short_id again if a worker lost track of it (e.g. if the worker is recovering from a crash). NOTE: it is possible that the response may have short ids for a subset of the metrics. Corresponds to the JSON property `metricShortId` @return [Array<Google::Apis::DataflowV1b3::MetricShortId>]
The index value to use for the next report sent by the worker. Note: If the report call fails for whatever reason, the worker should reuse this index for subsequent report attempts. Corresponds to the JSON property `nextReportIndex` @return [Fixnum]
New recommended reporting interval. Corresponds to the JSON property `reportStatusInterval` @return [String]
A suggestion by the service to the worker to dynamically split the WorkItem
. Corresponds to the JSON property `splitRequest` @return [Google::Apis::DataflowV1b3::ApproximateSplitRequest]
Obsolete in favor of ApproximateReportedProgress
and ApproximateSplitRequest
. Corresponds to the JSON property `suggestedStopPoint` @return [Google::Apis::DataflowV1b3::ApproximateProgress]
Position
defines a position within a collection of data. The value can be either the end position, a key (used with ordered collections), a byte offset, or a record index. Corresponds to the JSON property `suggestedStopPosition` @return [Google::Apis::DataflowV1b3::Position]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 6029 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 6034 def update!(**args) @complete_work_status = args[:complete_work_status] if args.key?(:complete_work_status) @harness_data = args[:harness_data] if args.key?(:harness_data) @hot_key_detection = args[:hot_key_detection] if args.key?(:hot_key_detection) @lease_expire_time = args[:lease_expire_time] if args.key?(:lease_expire_time) @metric_short_id = args[:metric_short_id] if args.key?(:metric_short_id) @next_report_index = args[:next_report_index] if args.key?(:next_report_index) @report_status_interval = args[:report_status_interval] if args.key?(:report_status_interval) @split_request = args[:split_request] if args.key?(:split_request) @suggested_stop_point = args[:suggested_stop_point] if args.key?(:suggested_stop_point) @suggested_stop_position = args[:suggested_stop_position] if args.key?(:suggested_stop_position) end