class Google::Apis::DataflowV1b3::StreamingComputationTask

A task which describes what action should be performed for the specified streaming computation ranges.

Attributes

computation_ranges[RW]

Contains ranges of a streaming computation this task should apply to. Corresponds to the JSON property `computationRanges` @return [Array<Google::Apis::DataflowV1b3::StreamingComputationRanges>]

data_disks[RW]

Describes the set of data disks this task should apply to. Corresponds to the JSON property `dataDisks` @return [Array<Google::Apis::DataflowV1b3::MountedDataDisk>]

task_type[RW]

A type of streaming computation task. Corresponds to the JSON property `taskType` @return [String]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5289
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 5294
def update!(**args)
  @computation_ranges = args[:computation_ranges] if args.key?(:computation_ranges)
  @data_disks = args[:data_disks] if args.key?(:data_disks)
  @task_type = args[:task_type] if args.key?(:task_type)
end