Class: Google::Apis::DatapipelinesV1::GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter

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

Overview

Launch Flex Template parameter.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter

Returns a new instance of GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter.



302
303
304
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 302

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

Instance Attribute Details

#container_spec_gcs_path ⇒ String

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

Returns:

  • (String) 


265
266
267
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 265

def container_spec_gcs_path
  @container_spec_gcs_path
end

#environment ⇒ Google::Apis::DatapipelinesV1::GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment

The environment values to be set at runtime for a Flex Template. Corresponds to the JSON property environment

Returns:



270
271
272
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 270

def environment
  @environment
end

#job_name ⇒ String

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

Returns:

  • (String) 


276
277
278
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 276

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


282
283
284
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 282

def launch_options
  @launch_options
end

#parameters ⇒ Hash<String,String>

The parameters for the Flex Template. Example: "num_workers":"5" Corresponds to the JSON property parameters

Returns:

  • (Hash<String,String>) 


287
288
289
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 287

def parameters
  @parameters
end

#transform_name_mappings ⇒ Hash<String,String>

Use this to pass transform name mappings for streaming update jobs. Example: "oldTransformName":"newTransformName",... Corresponds to the JSON property transformNameMappings

Returns:

  • (Hash<String,String>) 


293
294
295
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 293

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) 


299
300
301
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 299

def update
  @update
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



307
308
309
310
311
312
313
314
315
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 307

def update!(**args)
  @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