class Google::Apis::DataflowV1b3::ParDoInstruction

An instruction that does a ParDo operation. Takes one main input and zero or more side inputs, and produces zero or more outputs. Runs user code.

Attributes

input[RW]

An input of an instruction, as a reference to an output of a producer instruction. Corresponds to the JSON property `input` @return [Google::Apis::DataflowV1b3::InstructionInput]

multi_output_infos[RW]

Information about each of the outputs, if user_fn is a MultiDoFn. Corresponds to the JSON property `multiOutputInfos` @return [Array<Google::Apis::DataflowV1b3::MultiOutputInfo>]

num_outputs[RW]

The number of outputs. Corresponds to the JSON property `numOutputs` @return [Fixnum]

side_inputs[RW]

Zero or more side inputs. Corresponds to the JSON property `sideInputs` @return [Array<Google::Apis::DataflowV1b3::SideInputInfo>]

user_fn[RW]

The user function to invoke. Corresponds to the JSON property `userFn` @return [Hash<String,Object>]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3184
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 3189
def update!(**args)
  @input = args[:input] if args.key?(:input)
  @multi_output_infos = args[:multi_output_infos] if args.key?(:multi_output_infos)
  @num_outputs = args[:num_outputs] if args.key?(:num_outputs)
  @side_inputs = args[:side_inputs] if args.key?(:side_inputs)
  @user_fn = args[:user_fn] if args.key?(:user_fn)
end