- 0.57.0 (latest)
- 0.56.0
- 0.55.0
- 0.53.0
- 0.52.0
- 0.51.0
- 0.50.0
- 0.49.0
- 0.48.0
- 0.47.0
- 0.46.0
- 0.45.0
- 0.44.0
- 0.43.0
- 0.41.0
- 0.40.0
- 0.39.0
- 0.38.0
- 0.37.0
- 0.36.0
- 0.35.0
- 0.34.0
- 0.33.0
- 0.32.0
- 0.31.0
- 0.28.0
- 0.27.0
- 0.26.0
- 0.25.0
- 0.24.0
- 0.23.0
- 0.22.0
- 0.21.0
- 0.20.0
- 0.19.0
- 0.18.0
- 0.17.0
- 0.16.0
- 0.15.0
- 0.13.0
- 0.12.0
- 0.11.0
- 0.10.0
- 0.9.0
- 0.8.0
- 0.5.0
public interface RuntimeEnvironmentOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
containsAdditionalUserLabels(String key)
public abstract boolean containsAdditionalUserLabels(String key)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" }.
map<string, string> additional_user_labels = 10;
| Name | Description |
key | String |
| Type | Description |
boolean |
getAdditionalExperiments(int index)
public abstract String getAdditionalExperiments(int index) Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Name | Description |
index | intThe index of the element to return. |
| Type | Description |
String | The additionalExperiments at the given index. |
getAdditionalExperimentsBytes(int index)
public abstract ByteString getAdditionalExperimentsBytes(int index) Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Name | Description |
index | intThe index of the value to return. |
| Type | Description |
ByteString | The bytes of the additionalExperiments at the given index. |
getAdditionalExperimentsCount()
public abstract int getAdditionalExperimentsCount() Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Type | Description |
int | The count of additionalExperiments. |
getAdditionalExperimentsList()
public abstract List<String> getAdditionalExperimentsList() Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Type | Description |
List<String> | A list containing the additionalExperiments. |
getAdditionalUserLabels()
public abstract Map<String,String> getAdditionalUserLabels()Use #getAdditionalUserLabelsMap() instead.
| Type | Description |
Map<String,String> |
getAdditionalUserLabelsCount()
public abstract int getAdditionalUserLabelsCount()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" }.
map<string, string> additional_user_labels = 10;
| Type | Description |
int |
getAdditionalUserLabelsMap()
public abstract Map<String,String> getAdditionalUserLabelsMap()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" }.
map<string, string> additional_user_labels = 10;
| Type | Description |
Map<String,String> |
getAdditionalUserLabelsOrDefault(String key, String defaultValue)
public abstract String getAdditionalUserLabelsOrDefault(String key, String defaultValue)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" }.
map<string, string> additional_user_labels = 10;
| Name | Description |
key | String |
defaultValue | String |
| Type | Description |
String |
getAdditionalUserLabelsOrThrow(String key)
public abstract String getAdditionalUserLabelsOrThrow(String key)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" }.
map<string, string> additional_user_labels = 10;
| Name | Description |
key | String |
| Type | Description |
String |
getBypassTempDirValidation()
public abstract boolean getBypassTempDirValidation()Whether to bypass the safety checks for the job's temporary directory. Use with caution.
bool bypass_temp_dir_validation = 5;
| Type | Description |
boolean | The bypassTempDirValidation. |
getEnableStreamingEngine()
public abstract boolean getEnableStreamingEngine()Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 17;
| Type | Description |
boolean | The enableStreamingEngine. |
getIpConfiguration()
public abstract WorkerIPAddressConfiguration getIpConfiguration()Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
| Type | Description |
WorkerIPAddressConfiguration | The ipConfiguration. |
getIpConfigurationValue()
public abstract int getIpConfigurationValue()Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
| Type | Description |
int | The enum numeric value on the wire for ipConfiguration. |
getKmsKeyName()
public abstract String getKmsKeyName()Name for the Cloud KMS key for the job. Key format is: projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
string kms_key_name = 12;
| Type | Description |
String | The kmsKeyName. |
getKmsKeyNameBytes()
public abstract ByteString getKmsKeyNameBytes()Name for the Cloud KMS key for the job. Key format is: projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
string kms_key_name = 12;
| Type | Description |
ByteString | The bytes for kmsKeyName. |
getMachineType()
public abstract String getMachineType()The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;
| Type | Description |
String | The machineType. |
getMachineTypeBytes()
public abstract ByteString getMachineTypeBytes()The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;
| Type | Description |
ByteString | The bytes for machineType. |
getMaxWorkers()
public abstract int getMaxWorkers()The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
int32 max_workers = 1;
| Type | Description |
int | The maxWorkers. |
getNetwork()
public abstract String getNetwork()Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;
| Type | Description |
String | The network. |
getNetworkBytes()
public abstract ByteString getNetworkBytes()Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;
| Type | Description |
ByteString | The bytes for network. |
getNumWorkers()
public abstract int getNumWorkers()The initial number of Google Compute Engine instnaces for the job.
int32 num_workers = 11;
| Type | Description |
int | The numWorkers. |
getServiceAccountEmail()
public abstract String getServiceAccountEmail()The email address of the service account to run the job as.
string service_account_email = 3;
| Type | Description |
String | The serviceAccountEmail. |
getServiceAccountEmailBytes()
public abstract ByteString getServiceAccountEmailBytes()The email address of the service account to run the job as.
string service_account_email = 3;
| Type | Description |
ByteString | The bytes for serviceAccountEmail. |
getSubnetwork()
public abstract String getSubnetwork()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.
string subnetwork = 9;
| Type | Description |
String | The subnetwork. |
getSubnetworkBytes()
public abstract ByteString getSubnetworkBytes()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.
string subnetwork = 9;
| Type | Description |
ByteString | The bytes for subnetwork. |
getTempLocation()
public abstract String getTempLocation() The Cloud Storage path to use for temporary files.
Must be a valid Cloud Storage URL, beginning with gs://.
string temp_location = 4;
| Type | Description |
String | The tempLocation. |
getTempLocationBytes()
public abstract ByteString getTempLocationBytes() The Cloud Storage path to use for temporary files.
Must be a valid Cloud Storage URL, beginning with gs://.
string temp_location = 4;
| Type | Description |
ByteString | The bytes for tempLocation. |
getWorkerRegion()
public abstract String getWorkerRegion()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.
string worker_region = 15;
| Type | Description |
String | The workerRegion. |
getWorkerRegionBytes()
public abstract ByteString getWorkerRegionBytes()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.
string worker_region = 15;
| Type | Description |
ByteString | The bytes for workerRegion. |
getWorkerZone()
public abstract String getWorkerZone() 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.
string worker_zone = 16;
| Type | Description |
String | The workerZone. |
getWorkerZoneBytes()
public abstract ByteString getWorkerZoneBytes() 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.
string worker_zone = 16;
| Type | Description |
ByteString | The bytes for workerZone. |
getZone()
public abstract String getZone()The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 2;
| Type | Description |
String | The zone. |
getZoneBytes()
public abstract ByteString getZoneBytes()The Compute Engine availability zone for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 2;
| Type | Description |
ByteString | The bytes for zone. |