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

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/dataflow_v1b3/classes.rb,
lib/google/apis/dataflow_v1b3/representations.rb,
lib/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

Constructor Details

#initialize(**args) ⇒ WorkItemServiceState

Returns a new instance of WorkItemServiceState.



6373
6374
6375
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6373

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#complete_work_status ⇒ Google::Apis::DataflowV1b3::Status

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. 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. Corresponds to the JSON property completeWorkStatus

Returns:



6318
6319
6320
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6318

def complete_work_status
  @complete_work_status
end

#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>) 


6323
6324
6325
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6323

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

Returns:



6328
6329
6330
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6328

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

Returns:

  • (String) 


6333
6334
6335
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6333

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:



6342
6343
6344
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6342

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) 


6349
6350
6351
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6349

def next_report_index
  @next_report_index
end

#report_status_interval ⇒ String

New recommended reporting interval. Corresponds to the JSON property reportStatusInterval

Returns:

  • (String) 


6354
6355
6356
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6354

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:



6359
6360
6361
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6359

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:



6364
6365
6366
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6364

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:



6371
6372
6373
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6371

def suggested_stop_position
  @suggested_stop_position
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



6378
6379
6380
6381
6382
6383
6384
6385
6386
6387
6388
6389
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6378

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