Class: Google::Apis::DataflowV1b3::WorkItemServiceState

Inherits:
Object
  • Object
show all
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

Instance Method Summary collapse

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

Constructor Details

#initialize(**args) ⇒ WorkItemServiceState

Returns a new instance of WorkItemServiceState



4601
4602
4603
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4601

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

Returns:

  • (Hash<String,Object>) 


4555
4556
4557
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4555

def harness_data
  @harness_data
end

#lease_expire_time ⇒ String

Time at which the current lease will expire. Corresponds to the JSON property leaseExpireTime

Returns:

  • (String) 


4560
4561
4562
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4560

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

Returns:



4570
4571
4572
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4570

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

Returns:

  • (Fixnum) 


4577
4578
4579
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4577

def next_report_index
  @next_report_index
end

#report_status_interval ⇒ String

New recommended reporting interval. Corresponds to the JSON property reportStatusInterval

Returns:

  • (String) 


4582
4583
4584
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4582

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

Returns:



4587
4588
4589
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4587

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

Returns:



4592
4593
4594
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4592

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

Returns:



4599
4600
4601
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4599

def suggested_stop_position
  @suggested_stop_position
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



4606
4607
4608
4609
4610
4611
4612
4613
4614
4615
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4606

def update!(**args)
  @harness_data = args[:harness_data] if args.key?(:harness_data)
  @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