class Google::Apis::DataflowV1b3::WorkItem
WorkItem
represents basic information about a WorkItem
to be executed in the cloud.
Attributes
Work item-specific configuration as an opaque blob. Corresponds to the JSON property `configuration` @return [String]
Identifies this WorkItem
. Corresponds to the JSON property `id` @return [Fixnum]
The initial index to use when reporting the status of the WorkItem
. Corresponds to the JSON property `initialReportIndex` @return [Fixnum]
Identifies the workflow job this WorkItem
belongs to. Corresponds to the JSON property `jobId` @return [String]
Time when the lease on this Work will expire. Corresponds to the JSON property `leaseExpireTime` @return [String]
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` @return [Google::Apis::DataflowV1b3::MapTask]
Any required packages that need to be fetched in order to execute this WorkItem
. Corresponds to the JSON property `packages` @return [Array<Google::Apis::DataflowV1b3::Package>]
Identifies the cloud project this WorkItem
belongs to. Corresponds to the JSON property `projectId` @return [String]
Recommended reporting interval. Corresponds to the JSON property `reportStatusInterval` @return [String]
Describes a particular function to invoke. Corresponds to the JSON property `seqMapTask` @return [Google::Apis::DataflowV1b3::SeqMapTask]
A task which consists of a shell command for the worker to execute. Corresponds to the JSON property `shellTask` @return [Google::Apis::DataflowV1b3::ShellTask]
A work item that represents the different operations that can be performed on a user-defined Source
specification. Corresponds to the JSON property `sourceOperationTask` @return [Google::Apis::DataflowV1b3::SourceOperationRequest]
A task which describes what action should be performed for the specified streaming computation ranges. Corresponds to the JSON property `streamingComputationTask` @return [Google::Apis::DataflowV1b3::StreamingComputationTask]
A task that carries configuration information for streaming computations. Corresponds to the JSON property `streamingConfigTask` @return [Google::Apis::DataflowV1b3::StreamingConfigTask]
A task which initializes part of a streaming Dataflow job. Corresponds to the JSON property `streamingSetupTask` @return [Google::Apis::DataflowV1b3::StreamingSetupTask]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5881 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5886 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