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
5139 5140 5141 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5139 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
5060 5061 5062 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5060 def configuration @configuration end |
#id ⇒ Fixnum
Identifies this WorkItem.
Corresponds to the JSON property id
5065 5066 5067 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5065 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
5070 5071 5072 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5070 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
5075 5076 5077 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5075 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
5080 5081 5082 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5080 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
5089 5090 5091 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5089 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
5095 5096 5097 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5095 def packages @packages end |
#project_id ⇒ String
Identifies the cloud project this WorkItem belongs to.
Corresponds to the JSON property projectId
5100 5101 5102 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5100 def project_id @project_id end |
#report_status_interval ⇒ String
Recommended reporting interval.
Corresponds to the JSON property reportStatusInterval
5105 5106 5107 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5105 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
5110 5111 5112 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5110 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
5115 5116 5117 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5115 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
5121 5122 5123 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5121 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
5127 5128 5129 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5127 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
5132 5133 5134 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5132 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
5137 5138 5139 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5137 def streaming_setup_task @streaming_setup_task end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
5144 5145 5146 5147 5148 5149 5150 5151 5152 5153 5154 5155 5156 5157 5158 5159 5160 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 5144 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 |