Class: Google::Apis::DataflowV1b3::WorkItemServiceState
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::WorkItemServiceState
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb
Overview
The Dataflow service's idea of the current state of a WorkItem being processed by a worker.
Instance Attribute Summary collapse
-
#harness_data ⇒ Hash<String,Object>
Other data returned by the service, specific to the particular worker harness.
-
#hot_key_detection ⇒ Google::Apis::DataflowV1b3::HotKeyDetection
Proto describing a hot key detected on a given WorkItem.
-
#lease_expire_time ⇒ String
Time at which the current lease will expire.
-
#metric_short_id ⇒ Array<Google::Apis::DataflowV1b3::MetricShortId>
The short ids that workers should use in subsequent metric updates.
-
#next_report_index ⇒ Fixnum
The index value to use for the next report sent by the worker.
-
#report_status_interval ⇒ String
New recommended reporting interval.
-
#split_request ⇒ Google::Apis::DataflowV1b3::ApproximateSplitRequest
A suggestion by the service to the worker to dynamically split the WorkItem.
-
#suggested_stop_point ⇒ Google::Apis::DataflowV1b3::ApproximateProgress
Obsolete in favor of ApproximateReportedProgress and ApproximateSplitRequest.
-
#suggested_stop_position ⇒ Google::Apis::DataflowV1b3::Position
Position defines a position within a collection of data.
Instance Method Summary collapse
-
#initialize(**args) ⇒ WorkItemServiceState
constructor
A new instance of WorkItemServiceState.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ WorkItemServiceState
Returns a new instance of WorkItemServiceState.
5394 5395 5396 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5394 def initialize(**args) update!(**args) end |
Instance Attribute Details
#harness_data ⇒ Hash<String,Object>
Other data returned by the service, specific to the particular
worker harness.
Corresponds to the JSON property harnessData
5343 5344 5345 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5343 def harness_data @harness_data end |
#hot_key_detection ⇒ Google::Apis::DataflowV1b3::HotKeyDetection
Proto describing a hot key detected on a given WorkItem.
Corresponds to the JSON property hotKeyDetection
5348 5349 5350 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5348 def hot_key_detection @hot_key_detection end |
#lease_expire_time ⇒ String
Time at which the current lease will expire.
Corresponds to the JSON property leaseExpireTime
5353 5354 5355 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5353 def lease_expire_time @lease_expire_time end |
#metric_short_id ⇒ Array<Google::Apis::DataflowV1b3::MetricShortId>
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
5363 5364 5365 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5363 def metric_short_id @metric_short_id end |
#next_report_index ⇒ Fixnum
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
5370 5371 5372 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5370 def next_report_index @next_report_index end |
#report_status_interval ⇒ String
New recommended reporting interval.
Corresponds to the JSON property reportStatusInterval
5375 5376 5377 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5375 def report_status_interval @report_status_interval end |
#split_request ⇒ Google::Apis::DataflowV1b3::ApproximateSplitRequest
A suggestion by the service to the worker to dynamically split the WorkItem.
Corresponds to the JSON property splitRequest
5380 5381 5382 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5380 def split_request @split_request end |
#suggested_stop_point ⇒ Google::Apis::DataflowV1b3::ApproximateProgress
Obsolete in favor of ApproximateReportedProgress and ApproximateSplitRequest.
Corresponds to the JSON property suggestedStopPoint
5385 5386 5387 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5385 def suggested_stop_point @suggested_stop_point end |
#suggested_stop_position ⇒ Google::Apis::DataflowV1b3::Position
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
5392 5393 5394 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5392 def suggested_stop_position @suggested_stop_position end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
5399 5400 5401 5402 5403 5404 5405 5406 5407 5408 5409 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5399 def update!(**args) @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 |