class Google::Apis::DataflowV1b3::WorkItem

WorkItem represents basic information about a WorkItem to be executed in the cloud.

Attributes

configuration[RW]

Work item-specific configuration as an opaque blob. Corresponds to the JSON property `configuration` @return [String]

id[RW]

Identifies this WorkItem. Corresponds to the JSON property `id` @return [Fixnum]

initial_report_index[RW]

The initial index to use when reporting the status of the WorkItem. Corresponds to the JSON property `initialReportIndex` @return [Fixnum]

job_id[RW]

Identifies the workflow job this WorkItem belongs to. Corresponds to the JSON property `jobId` @return [String]

lease_expire_time[RW]

Time when the lease on this Work will expire. Corresponds to the JSON property `leaseExpireTime` @return [String]

map_task[RW]

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]

packages[RW]

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>]

project_id[RW]

Identifies the cloud project this WorkItem belongs to. Corresponds to the JSON property `projectId` @return [String]

report_status_interval[RW]

Recommended reporting interval. Corresponds to the JSON property `reportStatusInterval` @return [String]

seq_map_task[RW]

Describes a particular function to invoke. Corresponds to the JSON property `seqMapTask` @return [Google::Apis::DataflowV1b3::SeqMapTask]

shell_task[RW]

A task which consists of a shell command for the worker to execute. Corresponds to the JSON property `shellTask` @return [Google::Apis::DataflowV1b3::ShellTask]

source_operation_task[RW]

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]

streaming_computation_task[RW]

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]

streaming_config_task[RW]

A task that carries configuration information for streaming computations. Corresponds to the JSON property `streamingConfigTask` @return [Google::Apis::DataflowV1b3::StreamingConfigTask]

streaming_setup_task[RW]

A task which initializes part of a streaming Dataflow job. Corresponds to the JSON property `streamingSetupTask` @return [Google::Apis::DataflowV1b3::StreamingSetupTask]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5881
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

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