Class: Google::Apis::DataflowV1b3::LaunchFlexTemplateParameter

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

Launch FlexTemplate Parameter.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ LaunchFlexTemplateParameter

Returns a new instance of LaunchFlexTemplateParameter.



2848
2849
2850
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2848

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

Instance Attribute Details

#container_spec ⇒ Google::Apis::DataflowV1b3::ContainerSpec

Container Spec. Corresponds to the JSON property containerSpec

Returns:



2806
2807
2808
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2806

def container_spec
  @container_spec
end

#container_spec_gcs_path ⇒ String

Cloud Storage path to a file with json serialized ContainerSpec as content. Corresponds to the JSON property containerSpecGcsPath

Returns:

  • (String) 


2811
2812
2813
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2811

def container_spec_gcs_path
  @container_spec_gcs_path
end

#environment ⇒ Google::Apis::DataflowV1b3::FlexTemplateRuntimeEnvironment

The environment values to be set at runtime for flex template. LINT.IfChange Corresponds to the JSON property environment

Returns:



2816
2817
2818
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2816

def environment
  @environment
end

#job_name ⇒ String

Required. The job name to use for the created job. For update job request, job name should be same as the existing running job. Corresponds to the JSON property jobName

Returns:

  • (String) 


2822
2823
2824
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2822

def job_name
  @job_name
end

#launch_options ⇒ Hash<String,String>

Launch options for this flex template job. This is a common set of options across languages and templates. This should not be used to pass job parameters. Corresponds to the JSON property launchOptions

Returns:

  • (Hash<String,String>) 


2828
2829
2830
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2828

def launch_options
  @launch_options
end

#parameters ⇒ Hash<String,String>

The parameters for FlexTemplate. Ex. "num_workers":"5" Corresponds to the JSON property parameters

Returns:

  • (Hash<String,String>) 


2833
2834
2835
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2833

def parameters
  @parameters
end

#transform_name_mappings ⇒ Hash<String,String>

Use this to pass transform_name_mappings for streaming update jobs. Ex:" oldTransformName":"newTransformName",...' Corresponds to the JSON property transformNameMappings

Returns:

  • (Hash<String,String>) 


2839
2840
2841
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2839

def transform_name_mappings
  @transform_name_mappings
end

#update ⇒ Boolean Also known as: update?

Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job. Corresponds to the JSON property update

Returns:

  • (Boolean) 


2845
2846
2847
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2845

def update
  @update
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2853
2854
2855
2856
2857
2858
2859
2860
2861
2862
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 2853

def update!(**args)
  @container_spec = args[:container_spec] if args.key?(:container_spec)
  @container_spec_gcs_path = args[:container_spec_gcs_path] if args.key?(:container_spec_gcs_path)
  @environment = args[:environment] if args.key?(:environment)
  @job_name = args[:job_name] if args.key?(:job_name)
  @launch_options = args[:launch_options] if args.key?(:launch_options)
  @parameters = args[:parameters] if args.key?(:parameters)
  @transform_name_mappings = args[:transform_name_mappings] if args.key?(:transform_name_mappings)
  @update = args[:update] if args.key?(:update)
end