Class: Google::Apis::DataflowV1b3::WriteInstruction

Inherits:

Object

• Object
• Google::Apis::DataflowV1b3::WriteInstruction

Includes:

Core::Hashable, Core::JsonObjectSupport

Defined in:

generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb

Overview

An instruction that writes records. Takes one input, produces no outputs.

Instance Attribute Summary

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

  An input of an instruction, as a reference to an output of a producer instruction.

• #sink ⇒ Google::Apis::DataflowV1b3::Sink

  A sink that records can be encoded and written to.

Instance Method Summary

• #initialize(**args) ⇒ WriteInstruction constructor

  A new instance of WriteInstruction.

• #update!(**args) ⇒ Object

  Update properties of this object.

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

Constructor Details

#initialize(**args) ⇒ WriteInstruction

Returns a new instance of WriteInstruction.

# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2707

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:

• (Google::Apis::DataflowV1b3::InstructionInput)

# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2700

def input
  @input
end

#sink ⇒ Google::Apis::DataflowV1b3::Sink

A sink that records can be encoded and written to. Corresponds to the JSON property sink

Returns:

• (Google::Apis::DataflowV1b3::Sink)

# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2705

def sink
  @sink
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object

# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2712

def update!(**args)
  @input = args[:input] if args.key?(:input)
  @sink = args[:sink] if args.key?(:sink)
end