Class: Google::Apis::DataflowV1b3::ParDoInstruction

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/dataflow_v1b3/classes.rb,
lib/google/apis/dataflow_v1b3/representations.rb,
lib/google/apis/dataflow_v1b3/representations.rb

Overview

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.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ ParDoInstruction

Returns a new instance of ParDoInstruction.



3215
3216
3217
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3215

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#input ⇒ Google::Apis::DataflowV1b3::InstructionInput

An input of an instruction, as a reference to an output of a producer instruction. Corresponds to the JSON property input

Returns:



3193
3194
3195
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3193

def input
  @input
end

#multi_output_infos ⇒ Array<Google::Apis::DataflowV1b3::MultiOutputInfo>

Information about each of the outputs, if user_fn is a MultiDoFn. Corresponds to the JSON property multiOutputInfos

Returns:



3198
3199
3200
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3198

def multi_output_infos
  @multi_output_infos
end

#num_outputs ⇒ Fixnum

The number of outputs. Corresponds to the JSON property numOutputs

Returns:

  • (Fixnum) 


3203
3204
3205
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3203

def num_outputs
  @num_outputs
end

#side_inputs ⇒ Array<Google::Apis::DataflowV1b3::SideInputInfo>

Zero or more side inputs. Corresponds to the JSON property sideInputs

Returns:



3208
3209
3210
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3208

def side_inputs
  @side_inputs
end

#user_fn ⇒ Hash<String,Object>

The user function to invoke. Corresponds to the JSON property userFn

Returns:

  • (Hash<String,Object>) 


3213
3214
3215
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3213

def user_fn
  @user_fn
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



3220
3221
3222
3223
3224
3225
3226
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 3220

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