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
- (::Google::Cloud::Dataflow::V1beta3::ContainerSpec) — Spec about the container image to launch.
#container_spec=
def container_spec=(value) -> ::Google::Cloud::Dataflow::V1beta3::ContainerSpec
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::ContainerSpec) — Spec about the container image to launch.
Returns
- (::Google::Cloud::Dataflow::V1beta3::ContainerSpec) — Spec about the container image to launch.
#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
- (::Google::Cloud::Dataflow::V1beta3::FlexTemplateRuntimeEnvironment) — The runtime environment for the FlexTemplate job
#environment=
def environment=(value) -> ::Google::Cloud::Dataflow::V1beta3::FlexTemplateRuntimeEnvironment
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::FlexTemplateRuntimeEnvironment) — The runtime environment for the FlexTemplate job
Returns
- (::Google::Cloud::Dataflow::V1beta3::FlexTemplateRuntimeEnvironment) — The runtime environment for the FlexTemplate job
#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.