Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::LaunchFlexTemplateParameter (v0.8.0)

Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::LaunchFlexTemplateParameter.

Launch FlexTemplate Parameter.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#container_spec

def container_spec() -> ::Google::Cloud::Dataflow::V1beta3::ContainerSpec
Returns

#container_spec=

def container_spec=(value) -> ::Google::Cloud::Dataflow::V1beta3::ContainerSpec
Parameter
Returns

#container_spec_gcs_path

def container_spec_gcs_path() -> ::String
Returns
  • (::String) — Cloud Storage path to a file with json serialized ContainerSpec as content.

#container_spec_gcs_path=

def container_spec_gcs_path=(value) -> ::String
Parameter
  • value (::String) — Cloud Storage path to a file with json serialized ContainerSpec as content.
Returns
  • (::String) — Cloud Storage path to a file with json serialized ContainerSpec as content.

#environment

def environment() -> ::Google::Cloud::Dataflow::V1beta3::FlexTemplateRuntimeEnvironment
Returns

#environment=

def environment=(value) -> ::Google::Cloud::Dataflow::V1beta3::FlexTemplateRuntimeEnvironment
Parameter
Returns

#job_name

def job_name() -> ::String
Returns
  • (::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.

#job_name=

def job_name=(value) -> ::String
Parameter
  • value (::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.
Returns
  • (::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.

#launch_options

def launch_options() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::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.

#launch_options=

def launch_options=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::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.
Returns
  • (::Google::Protobuf::Map{::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.

#parameters

def parameters() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — The parameters for FlexTemplate. Ex. {"num_workers":"5"}

#parameters=

def parameters=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::String => ::String}) — The parameters for FlexTemplate. Ex. {"num_workers":"5"}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — The parameters for FlexTemplate. Ex. {"num_workers":"5"}

#transform_name_mappings

def transform_name_mappings() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Use this to pass transform_name_mappings for streaming update jobs. Ex:{"oldTransformName":"newTransformName",...}'

#transform_name_mappings=

def transform_name_mappings=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::String => ::String}) — Use this to pass transform_name_mappings for streaming update jobs. Ex:{"oldTransformName":"newTransformName",...}'
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Use this to pass transform_name_mappings for streaming update jobs. Ex:{"oldTransformName":"newTransformName",...}'

#update

def update() -> ::Boolean
Returns
  • (::Boolean) — 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.

#update=

def update=(value) -> ::Boolean
Parameter
  • value (::Boolean) — 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.
Returns
  • (::Boolean) — 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.