Class: Google::Apis::DataflowV1b3::WorkItem
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::WorkItem
- 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
WorkItem represents basic information about a WorkItem to be executed in the cloud.
Instance Attribute Summary collapse
-
#configuration ⇒ String
Work item-specific configuration as an opaque blob.
-
#id ⇒ Fixnum
Identifies this WorkItem.
-
#initial_report_index ⇒ Fixnum
The initial index to use when reporting the status of the WorkItem.
-
#job_id ⇒ String
Identifies the workflow job this WorkItem belongs to.
-
#lease_expire_time ⇒ String
Time when the lease on this Work will expire.
-
#map_task ⇒ Google::Apis::DataflowV1b3::MapTask
MapTask consists of an ordered set of instructions, each of which describes one particular low-level operation for the worker to perform in order to accomplish the MapTask's WorkItem.
-
#packages ⇒ Array<Google::Apis::DataflowV1b3::Package>
Any required packages that need to be fetched in order to execute this WorkItem.
-
#project_id ⇒ String
Identifies the cloud project this WorkItem belongs to.
-
#report_status_interval ⇒ String
Recommended reporting interval.
-
#seq_map_task ⇒ Google::Apis::DataflowV1b3::SeqMapTask
Describes a particular function to invoke.
-
#shell_task ⇒ Google::Apis::DataflowV1b3::ShellTask
A task which consists of a shell command for the worker to execute.
-
#source_operation_task ⇒ Google::Apis::DataflowV1b3::SourceOperationRequest
A work item that represents the different operations that can be performed on a user-defined Source specification.
-
#streaming_computation_task ⇒ Google::Apis::DataflowV1b3::StreamingComputationTask
A task which describes what action should be performed for the specified streaming computation ranges.
-
#streaming_config_task ⇒ Google::Apis::DataflowV1b3::StreamingConfigTask
A task that carries configuration information for streaming computations.
-
#streaming_setup_task ⇒ Google::Apis::DataflowV1b3::StreamingSetupTask
A task which initializes part of a streaming Dataflow job.
Instance Method Summary collapse
-
#initialize(**args) ⇒ WorkItem
constructor
A new instance of WorkItem.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ WorkItem
Returns a new instance of WorkItem
4590 4591 4592 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4590 def initialize(**args) update!(**args) end |
Instance Attribute Details
#configuration ⇒ String
Work item-specific configuration as an opaque blob.
Corresponds to the JSON property configuration
4511 4512 4513 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4511 def configuration @configuration end |
#id ⇒ Fixnum
Identifies this WorkItem.
Corresponds to the JSON property id
4516 4517 4518 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4516 def id @id end |
#initial_report_index ⇒ Fixnum
The initial index to use when reporting the status of the WorkItem.
Corresponds to the JSON property initialReportIndex
4521 4522 4523 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4521 def initial_report_index @initial_report_index end |
#job_id ⇒ String
Identifies the workflow job this WorkItem belongs to.
Corresponds to the JSON property jobId
4526 4527 4528 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4526 def job_id @job_id end |
#lease_expire_time ⇒ String
Time when the lease on this Work will expire.
Corresponds to the JSON property leaseExpireTime
4531 4532 4533 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4531 def lease_expire_time @lease_expire_time end |
#map_task ⇒ Google::Apis::DataflowV1b3::MapTask
MapTask consists of an ordered set of instructions, each of which
describes one particular low-level operation for the worker to
perform in order to accomplish the MapTask's WorkItem.
Each instruction must appear in the list before any instructions which
depends on its output.
Corresponds to the JSON property mapTask
4540 4541 4542 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4540 def map_task @map_task end |
#packages ⇒ Array<Google::Apis::DataflowV1b3::Package>
Any required packages that need to be fetched in order to execute
this WorkItem.
Corresponds to the JSON property packages
4546 4547 4548 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4546 def packages @packages end |
#project_id ⇒ String
Identifies the cloud project this WorkItem belongs to.
Corresponds to the JSON property projectId
4551 4552 4553 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4551 def project_id @project_id end |
#report_status_interval ⇒ String
Recommended reporting interval.
Corresponds to the JSON property reportStatusInterval
4556 4557 4558 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4556 def report_status_interval @report_status_interval end |
#seq_map_task ⇒ Google::Apis::DataflowV1b3::SeqMapTask
Describes a particular function to invoke.
Corresponds to the JSON property seqMapTask
4561 4562 4563 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4561 def seq_map_task @seq_map_task end |
#shell_task ⇒ Google::Apis::DataflowV1b3::ShellTask
A task which consists of a shell command for the worker to execute.
Corresponds to the JSON property shellTask
4566 4567 4568 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4566 def shell_task @shell_task end |
#source_operation_task ⇒ Google::Apis::DataflowV1b3::SourceOperationRequest
A work item that represents the different operations that can be
performed on a user-defined Source specification.
Corresponds to the JSON property sourceOperationTask
4572 4573 4574 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4572 def source_operation_task @source_operation_task end |
#streaming_computation_task ⇒ Google::Apis::DataflowV1b3::StreamingComputationTask
A task which describes what action should be performed for the specified
streaming computation ranges.
Corresponds to the JSON property streamingComputationTask
4578 4579 4580 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4578 def streaming_computation_task @streaming_computation_task end |
#streaming_config_task ⇒ Google::Apis::DataflowV1b3::StreamingConfigTask
A task that carries configuration information for streaming computations.
Corresponds to the JSON property streamingConfigTask
4583 4584 4585 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4583 def streaming_config_task @streaming_config_task end |
#streaming_setup_task ⇒ Google::Apis::DataflowV1b3::StreamingSetupTask
A task which initializes part of a streaming Dataflow job.
Corresponds to the JSON property streamingSetupTask
4588 4589 4590 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4588 def streaming_setup_task @streaming_setup_task end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
4595 4596 4597 4598 4599 4600 4601 4602 4603 4604 4605 4606 4607 4608 4609 4610 4611 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4595 def update!(**args) @configuration = args[:configuration] if args.key?(:configuration) @id = args[:id] if args.key?(:id) @initial_report_index = args[:initial_report_index] if args.key?(:initial_report_index) @job_id = args[:job_id] if args.key?(:job_id) @lease_expire_time = args[:lease_expire_time] if args.key?(:lease_expire_time) @map_task = args[:map_task] if args.key?(:map_task) @packages = args[:packages] if args.key?(:packages) @project_id = args[:project_id] if args.key?(:project_id) @report_status_interval = args[:report_status_interval] if args.key?(:report_status_interval) @seq_map_task = args[:seq_map_task] if args.key?(:seq_map_task) @shell_task = args[:shell_task] if args.key?(:shell_task) @source_operation_task = args[:source_operation_task] if args.key?(:source_operation_task) @streaming_computation_task = args[:streaming_computation_task] if args.key?(:streaming_computation_task) @streaming_config_task = args[:streaming_config_task] if args.key?(:streaming_config_task) @streaming_setup_task = args[:streaming_setup_task] if args.key?(:streaming_setup_task) end |