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

Inherits:
Object
  • Object
show all
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

Launch FlexTemplate Parameter.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ LaunchFlexTemplateParameter

Returns a new instance of LaunchFlexTemplateParameter.



2514
2515
2516
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2514

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

Instance Attribute Details

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

Container Spec. Corresponds to the JSON property containerSpec

Returns:



2472
2473
2474
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2472

def container_spec
  @container_spec
end

#container_spec_gcs_path ⇒ String

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

Returns:

  • (String) 


2477
2478
2479
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2477

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. Corresponds to the JSON property environment

Returns:



2482
2483
2484
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2482

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) 


2488
2489
2490
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2488

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>) 


2494
2495
2496
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2494

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>) 


2499
2500
2501
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2499

def parameters
  @parameters
end

#transform_name_mappings ⇒ Hash<String,String>

Users need to set transform_name_mappings Ex:"oldTransformName":" newTransformName",...' Corresponds to the JSON property transformNameMappings

Returns:

  • (Hash<String,String>) 


2505
2506
2507
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2505

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) 


2511
2512
2513
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2511

def update
  @update
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



2519
2520
2521
2522
2523
2524
2525
2526
2527
2528
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 2519

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