Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::RuntimeEnvironment (v0.11.0)

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

The environment values to set at runtime.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#additional_experiments

def additional_experiments() -> ::Array<::String>
Returns
  • (::Array<::String>) — Additional experiment flags for the job, specified with the --experiments option.

#additional_experiments=

def additional_experiments=(value) -> ::Array<::String>
Parameter
  • value (::Array<::String>) — Additional experiment flags for the job, specified with the --experiments option.
Returns
  • (::Array<::String>) — Additional experiment flags for the job, specified with the --experiments option.

#additional_user_labels

def additional_user_labels() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the labeling restrictions page. An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.

#additional_user_labels=

def additional_user_labels=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::String => ::String}) — Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the labeling restrictions page. An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Additional user labels to be specified for the job. Keys and values should follow the restrictions specified in the labeling restrictions page. An object containing a list of "key": value pairs. Example: { "name": "wrench", "mass": "1kg", "count": "3" }.

#bypass_temp_dir_validation

def bypass_temp_dir_validation() -> ::Boolean
Returns
  • (::Boolean) — Whether to bypass the safety checks for the job's temporary directory. Use with caution.

#bypass_temp_dir_validation=

def bypass_temp_dir_validation=(value) -> ::Boolean
Parameter
  • value (::Boolean) — Whether to bypass the safety checks for the job's temporary directory. Use with caution.
Returns
  • (::Boolean) — Whether to bypass the safety checks for the job's temporary directory. Use with caution.

#enable_streaming_engine

def enable_streaming_engine() -> ::Boolean
Returns
  • (::Boolean) — Whether to enable Streaming Engine for the job.

#enable_streaming_engine=

def enable_streaming_engine=(value) -> ::Boolean
Parameter
  • value (::Boolean) — Whether to enable Streaming Engine for the job.
Returns
  • (::Boolean) — Whether to enable Streaming Engine for the job.

#ip_configuration

def ip_configuration() -> ::Google::Cloud::Dataflow::V1beta3::WorkerIPAddressConfiguration
Returns

#ip_configuration=

def ip_configuration=(value) -> ::Google::Cloud::Dataflow::V1beta3::WorkerIPAddressConfiguration
Parameter
Returns

#kms_key_name

def kms_key_name() -> ::String
Returns
  • (::String) — Name for the Cloud KMS key for the job. Key format is: projects/

#kms_key_name=

def kms_key_name=(value) -> ::String
Parameter
  • value (::String) — Name for the Cloud KMS key for the job. Key format is: projects/
Returns
  • (::String) — Name for the Cloud KMS key for the job. Key format is: projects/

#machine_type

def machine_type() -> ::String
Returns
  • (::String) — The machine type to use for the job. Defaults to the value from the template if not specified.

#machine_type=

def machine_type=(value) -> ::String
Parameter
  • value (::String) — The machine type to use for the job. Defaults to the value from the template if not specified.
Returns
  • (::String) — The machine type to use for the job. Defaults to the value from the template if not specified.

#max_workers

def max_workers() -> ::Integer
Returns
  • (::Integer) — The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

#max_workers=

def max_workers=(value) -> ::Integer
Parameter
  • value (::Integer) — The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
Returns
  • (::Integer) — The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

#network

def network() -> ::String
Returns
  • (::String) — Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

#network=

def network=(value) -> ::String
Parameter
  • value (::String) — Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
Returns
  • (::String) — Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".

#num_workers

def num_workers() -> ::Integer
Returns
  • (::Integer) — The initial number of Google Compute Engine instnaces for the job.

#num_workers=

def num_workers=(value) -> ::Integer
Parameter
  • value (::Integer) — The initial number of Google Compute Engine instnaces for the job.
Returns
  • (::Integer) — The initial number of Google Compute Engine instnaces for the job.

#service_account_email

def service_account_email() -> ::String
Returns
  • (::String) — The email address of the service account to run the job as.

#service_account_email=

def service_account_email=(value) -> ::String
Parameter
  • value (::String) — The email address of the service account to run the job as.
Returns
  • (::String) — The email address of the service account to run the job as.

#subnetwork

def subnetwork() -> ::String
Returns
  • (::String) — Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

#subnetwork=

def subnetwork=(value) -> ::String
Parameter
  • value (::String) — Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
Returns
  • (::String) — Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.

#temp_location

def temp_location() -> ::String
Returns
  • (::String) — The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://.

#temp_location=

def temp_location=(value) -> ::String
Parameter
  • value (::String) — The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://.
Returns
  • (::String) — The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://.

#worker_region

def worker_region() -> ::String
Returns
  • (::String) — The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.

#worker_region=

def worker_region=(value) -> ::String
Parameter
  • value (::String) — The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
Returns
  • (::String) — The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.

#worker_zone

def worker_zone() -> ::String
Returns
  • (::String) — The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both worker_zone and zone are set, worker_zone takes precedence.

#worker_zone=

def worker_zone=(value) -> ::String
Parameter
  • value (::String) — The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both worker_zone and zone are set, worker_zone takes precedence.
Returns
  • (::String) — The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a". Mutually exclusive with worker_region. If neither worker_region nor worker_zone is specified, a zone in the control plane's region is chosen based on available capacity. If both worker_zone and zone are set, worker_zone takes precedence.

#zone

def zone() -> ::String
Returns
  • (::String) — The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.

#zone=

def zone=(value) -> ::String
Parameter
  • value (::String) — The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
Returns
  • (::String) — The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.