getAdditionalUserLabelsMap();
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values must follow the restrictions specified in the [labeling
* restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
*/
/* nullable */
java.lang.String getAdditionalUserLabelsOrDefault(
java.lang.String key,
/* nullable */
java.lang.String defaultValue);
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values must follow the restrictions specified in the [labeling
* restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
*/
java.lang.String getAdditionalUserLabelsOrThrow(java.lang.String key);
/**
*
*
*
* Name for the Cloud KMS key for the job.
* Key format is:
* projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
*
*
* string kms_key_name = 11;
*
* @return The kmsKeyName.
*/
java.lang.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 = 11;
*
* @return The bytes for kmsKeyName.
*/
com.google.protobuf.ByteString getKmsKeyNameBytes();
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
*
* @return The enum numeric value on the wire for ipConfiguration.
*/
int getIpConfigurationValue();
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
*
* @return The ipConfiguration.
*/
com.google.dataflow.v1beta3.WorkerIPAddressConfiguration getIpConfiguration();
/**
*
*
*
* 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 = 13;
*
* @return The workerRegion.
*/
java.lang.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 = 13;
*
* @return The bytes for workerRegion.
*/
com.google.protobuf.ByteString getWorkerRegionBytes();
/**
*
*
*
* 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 = 14;
*
* @return The workerZone.
*/
java.lang.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 = 14;
*
* @return The bytes for workerZone.
*/
com.google.protobuf.ByteString getWorkerZoneBytes();
/**
*
*
*
* Whether to enable Streaming Engine for the job.
*
*
* bool enable_streaming_engine = 15;
*
* @return The enableStreamingEngine.
*/
boolean getEnableStreamingEngine();
/**
*
*
*
* Set FlexRS goal for the job.
* https://cloud.google.com/dataflow/docs/guides/flexrs
*
*
* .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
*
* @return The enum numeric value on the wire for flexrsGoal.
*/
int getFlexrsGoalValue();
/**
*
*
*
* Set FlexRS goal for the job.
* https://cloud.google.com/dataflow/docs/guides/flexrs
*
*
* .google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
*
* @return The flexrsGoal.
*/
com.google.dataflow.v1beta3.FlexResourceSchedulingGoal getFlexrsGoal();
/**
*
*
*
* The Cloud Storage path for staging local files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string staging_location = 17;
*
* @return The stagingLocation.
*/
java.lang.String getStagingLocation();
/**
*
*
*
* The Cloud Storage path for staging local files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string staging_location = 17;
*
* @return The bytes for stagingLocation.
*/
com.google.protobuf.ByteString getStagingLocationBytes();
/**
*
*
*
* Docker registry location of container image to use for the 'worker harness.
* Default is the container for the version of the SDK. Note this field is
* only valid for portable pipelines.
*
*
* string sdk_container_image = 18;
*
* @return The sdkContainerImage.
*/
java.lang.String getSdkContainerImage();
/**
*
*
*
* Docker registry location of container image to use for the 'worker harness.
* Default is the container for the version of the SDK. Note this field is
* only valid for portable pipelines.
*
*
* string sdk_container_image = 18;
*
* @return The bytes for sdkContainerImage.
*/
com.google.protobuf.ByteString getSdkContainerImageBytes();
/**
*
*
*
* Worker disk size, in gigabytes.
*
*
* int32 disk_size_gb = 20;
*
* @return The diskSizeGb.
*/
int getDiskSizeGb();
/**
*
*
*
* The algorithm to use for autoscaling
*
*
* .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
*
* @return The enum numeric value on the wire for autoscalingAlgorithm.
*/
int getAutoscalingAlgorithmValue();
/**
*
*
*
* The algorithm to use for autoscaling
*
*
* .google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
*
* @return The autoscalingAlgorithm.
*/
com.google.dataflow.v1beta3.AutoscalingAlgorithm getAutoscalingAlgorithm();
/**
*
*
*
* If true, save a heap dump before killing a thread or process which is GC
* thrashing or out of memory. The location of the heap file will either be
* echoed back to the user, or the user will be given the opportunity to
* download the heap file.
*
*
* bool dump_heap_on_oom = 22;
*
* @return The dumpHeapOnOom.
*/
boolean getDumpHeapOnOom();
/**
*
*
*
* Cloud Storage bucket (directory) to upload heap dumps to the given
* location. Enabling this implies that heap dumps should be generated on OOM
* (dump_heap_on_oom is set to true).
*
*
* string save_heap_dumps_to_gcs_path = 23;
*
* @return The saveHeapDumpsToGcsPath.
*/
java.lang.String getSaveHeapDumpsToGcsPath();
/**
*
*
*
* Cloud Storage bucket (directory) to upload heap dumps to the given
* location. Enabling this implies that heap dumps should be generated on OOM
* (dump_heap_on_oom is set to true).
*
*
* string save_heap_dumps_to_gcs_path = 23;
*
* @return The bytes for saveHeapDumpsToGcsPath.
*/
com.google.protobuf.ByteString getSaveHeapDumpsToGcsPathBytes();
/**
*
*
*
* The machine type to use for launching the job. The default is
* n1-standard-1.
*
*
* string launcher_machine_type = 24;
*
* @return The launcherMachineType.
*/
java.lang.String getLauncherMachineType();
/**
*
*
*
* The machine type to use for launching the job. The default is
* n1-standard-1.
*
*
* string launcher_machine_type = 24;
*
* @return The bytes for launcherMachineType.
*/
com.google.protobuf.ByteString getLauncherMachineTypeBytes();
}