Package com.google.dataflow.v1beta3
Class FlexTemplateRuntimeEnvironment.Builder
java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
com.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment.Builder
- All Implemented Interfaces:
FlexTemplateRuntimeEnvironmentOrBuilder,com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Cloneable
- Enclosing class:
- FlexTemplateRuntimeEnvironment
public static final class FlexTemplateRuntimeEnvironment.Builder
extends com.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
implements FlexTemplateRuntimeEnvironmentOrBuilder
The environment values to be set at runtime for flex template.Protobuf type
google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment-
Method Summary
Modifier and TypeMethodDescriptionaddAdditionalExperiments(String value) Additional experiment flags for the job.addAdditionalExperimentsBytes(com.google.protobuf.ByteString value) Additional experiment flags for the job.Optional.addAdditionalPipelineOptionsBytes(com.google.protobuf.ByteString value) Optional.addAllAdditionalExperiments(Iterable<String> values) Additional experiment flags for the job.Optional.build()clear()Additional experiment flags for the job.Optional.The algorithm to use for autoscalingWorker disk size, in gigabytes.If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process.If true serial port logging will be enabled for the launcher VM.Whether to enable Streaming Engine for the job.Set FlexRS goal for the job.Configuration for VM IPs.Name for the Cloud KMS key for the job.The machine type to use for launching the job.The machine type to use for the job.The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.Network to which VMs will be assigned.The initial number of Google Compute Engine instances for the job.Cloud Storage bucket (directory) to upload heap dumps to.Docker registry location of container image to use for the 'worker harness.The email address of the service account to run the job as.The Cloud Storage path for staging local files.Optional.Subnetwork to which VMs will be assigned, if desired.The Cloud Storage path to use for temporary files.The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.booleanAdditional user labels to be specified for the job.getAdditionalExperiments(int index) Additional experiment flags for the job.com.google.protobuf.ByteStringgetAdditionalExperimentsBytes(int index) Additional experiment flags for the job.intAdditional experiment flags for the job.com.google.protobuf.ProtocolStringListAdditional experiment flags for the job.getAdditionalPipelineOptions(int index) Optional.com.google.protobuf.ByteStringgetAdditionalPipelineOptionsBytes(int index) Optional.intOptional.com.google.protobuf.ProtocolStringListOptional.Deprecated.intAdditional user labels to be specified for the job.Additional user labels to be specified for the job.getAdditionalUserLabelsOrDefault(String key, String defaultValue) Additional user labels to be specified for the job.Additional user labels to be specified for the job.The algorithm to use for autoscalingintThe algorithm to use for autoscalingstatic final com.google.protobuf.Descriptors.Descriptorcom.google.protobuf.Descriptors.DescriptorintWorker disk size, in gigabytes.booleanIf true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process.booleanIf true serial port logging will be enabled for the launcher VM.booleanWhether to enable Streaming Engine for the job.Set FlexRS goal for the job.intSet FlexRS goal for the job.Configuration for VM IPs.intConfiguration for VM IPs.Name for the Cloud KMS key for the job.com.google.protobuf.ByteStringName for the Cloud KMS key for the job.The machine type to use for launching the job.com.google.protobuf.ByteStringThe machine type to use for launching the job.The machine type to use for the job.com.google.protobuf.ByteStringThe machine type to use for the job.intThe maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.Deprecated.Network to which VMs will be assigned.com.google.protobuf.ByteStringNetwork to which VMs will be assigned.intThe initial number of Google Compute Engine instances for the job.Cloud Storage bucket (directory) to upload heap dumps to.com.google.protobuf.ByteStringCloud Storage bucket (directory) to upload heap dumps to.Docker registry location of container image to use for the 'worker harness.com.google.protobuf.ByteStringDocker registry location of container image to use for the 'worker harness.The email address of the service account to run the job as.com.google.protobuf.ByteStringThe email address of the service account to run the job as.The Cloud Storage path for staging local files.com.google.protobuf.ByteStringThe Cloud Storage path for staging local files.Optional.intOptional.Subnetwork to which VMs will be assigned, if desired.com.google.protobuf.ByteStringSubnetwork to which VMs will be assigned, if desired.The Cloud Storage path to use for temporary files.com.google.protobuf.ByteStringThe Cloud Storage path to use for temporary files.The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.com.google.protobuf.ByteStringThe Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.com.google.protobuf.ByteStringThe Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.getZone()The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.com.google.protobuf.ByteStringThe Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.booleanOptional.protected com.google.protobuf.GeneratedMessage.FieldAccessorTableprotected com.google.protobuf.MapFieldReflectionAccessorinternalGetMapFieldReflection(int number) protected com.google.protobuf.MapFieldReflectionAccessorinternalGetMutableMapFieldReflection(int number) final booleanmergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom(com.google.protobuf.Message other) putAdditionalUserLabels(String key, String value) Additional user labels to be specified for the job.putAllAdditionalUserLabels(Map<String, String> values) Additional user labels to be specified for the job.Additional user labels to be specified for the job.setAdditionalExperiments(int index, String value) Additional experiment flags for the job.setAdditionalPipelineOptions(int index, String value) Optional.The algorithm to use for autoscalingsetAutoscalingAlgorithmValue(int value) The algorithm to use for autoscalingsetDiskSizeGb(int value) Worker disk size, in gigabytes.setDumpHeapOnOom(boolean value) If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process.setEnableLauncherVmSerialPortLogging(boolean value) If true serial port logging will be enabled for the launcher VM.setEnableStreamingEngine(boolean value) Whether to enable Streaming Engine for the job.Set FlexRS goal for the job.setFlexrsGoalValue(int value) Set FlexRS goal for the job.Configuration for VM IPs.setIpConfigurationValue(int value) Configuration for VM IPs.setKmsKeyName(String value) Name for the Cloud KMS key for the job.setKmsKeyNameBytes(com.google.protobuf.ByteString value) Name for the Cloud KMS key for the job.setLauncherMachineType(String value) The machine type to use for launching the job.setLauncherMachineTypeBytes(com.google.protobuf.ByteString value) The machine type to use for launching the job.setMachineType(String value) The machine type to use for the job.setMachineTypeBytes(com.google.protobuf.ByteString value) The machine type to use for the job.setMaxWorkers(int value) The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.setNetwork(String value) Network to which VMs will be assigned.setNetworkBytes(com.google.protobuf.ByteString value) Network to which VMs will be assigned.setNumWorkers(int value) The initial number of Google Compute Engine instances for the job.setSaveHeapDumpsToGcsPath(String value) Cloud Storage bucket (directory) to upload heap dumps to.setSaveHeapDumpsToGcsPathBytes(com.google.protobuf.ByteString value) Cloud Storage bucket (directory) to upload heap dumps to.setSdkContainerImage(String value) Docker registry location of container image to use for the 'worker harness.setSdkContainerImageBytes(com.google.protobuf.ByteString value) Docker registry location of container image to use for the 'worker harness.setServiceAccountEmail(String value) The email address of the service account to run the job as.setServiceAccountEmailBytes(com.google.protobuf.ByteString value) The email address of the service account to run the job as.setStagingLocation(String value) The Cloud Storage path for staging local files.setStagingLocationBytes(com.google.protobuf.ByteString value) The Cloud Storage path for staging local files.setStreamingMode(StreamingMode value) Optional.setStreamingModeValue(int value) Optional.setSubnetwork(String value) Subnetwork to which VMs will be assigned, if desired.setSubnetworkBytes(com.google.protobuf.ByteString value) Subnetwork to which VMs will be assigned, if desired.setTempLocation(String value) The Cloud Storage path to use for temporary files.setTempLocationBytes(com.google.protobuf.ByteString value) The Cloud Storage path to use for temporary files.setWorkerRegion(String value) The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.setWorkerRegionBytes(com.google.protobuf.ByteString value) The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.setWorkerZone(String value) The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.setWorkerZoneBytes(com.google.protobuf.ByteString value) The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.setZoneBytes(com.google.protobuf.ByteString value) The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.Methods inherited from class com.google.protobuf.GeneratedMessage.Builder
addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownFields, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields, setUnknownFieldSetBuilder, setUnknownFieldsProto3Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageExceptionMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFromMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
internalGetMapFieldReflection
protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number) - Overrides:
internalGetMapFieldReflectionin classcom.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
internalGetMutableMapFieldReflection
protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number) - Overrides:
internalGetMutableMapFieldReflectionin classcom.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
clear
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>
-
mergeFrom
public FlexTemplateRuntimeEnvironment.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<FlexTemplateRuntimeEnvironment.Builder>- Throws:
IOException
-
getNumWorkers
public int getNumWorkers()The initial number of Google Compute Engine instances for the job.
int32 num_workers = 1;- Specified by:
getNumWorkersin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The numWorkers.
-
setNumWorkers
The initial number of Google Compute Engine instances for the job.
int32 num_workers = 1;- Parameters:
value- The numWorkers to set.- Returns:
- This builder for chaining.
-
clearNumWorkers
The initial number of Google Compute Engine instances for the job.
int32 num_workers = 1;- Returns:
- This builder for chaining.
-
getMaxWorkers
public 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 = 2;- Specified by:
getMaxWorkersin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The maxWorkers.
-
setMaxWorkers
The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
int32 max_workers = 2;- Parameters:
value- The maxWorkers to set.- Returns:
- This builder for chaining.
-
clearMaxWorkers
The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.
int32 max_workers = 2;- Returns:
- This builder for chaining.
-
getZone
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;- Specified by:
getZonein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The zone.
-
getZoneBytes
public com.google.protobuf.ByteString getZoneBytes()The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;- Specified by:
getZoneBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for zone.
-
setZone
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;- Parameters:
value- The zone to set.- Returns:
- This builder for chaining.
-
clearZone
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;- Returns:
- This builder for chaining.
-
setZoneBytes
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;- Parameters:
value- The bytes for zone to set.- Returns:
- This builder for chaining.
-
getServiceAccountEmail
The email address of the service account to run the job as.
string service_account_email = 4;- Specified by:
getServiceAccountEmailin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The serviceAccountEmail.
-
getServiceAccountEmailBytes
public com.google.protobuf.ByteString getServiceAccountEmailBytes()The email address of the service account to run the job as.
string service_account_email = 4;- Specified by:
getServiceAccountEmailBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for serviceAccountEmail.
-
setServiceAccountEmail
The email address of the service account to run the job as.
string service_account_email = 4;- Parameters:
value- The serviceAccountEmail to set.- Returns:
- This builder for chaining.
-
clearServiceAccountEmail
The email address of the service account to run the job as.
string service_account_email = 4;- Returns:
- This builder for chaining.
-
setServiceAccountEmailBytes
public FlexTemplateRuntimeEnvironment.Builder setServiceAccountEmailBytes(com.google.protobuf.ByteString value) The email address of the service account to run the job as.
string service_account_email = 4;- Parameters:
value- The bytes for serviceAccountEmail to set.- Returns:
- This builder for chaining.
-
getTempLocation
The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 5;- Specified by:
getTempLocationin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The tempLocation.
-
getTempLocationBytes
public com.google.protobuf.ByteString getTempLocationBytes()The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 5;- Specified by:
getTempLocationBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for tempLocation.
-
setTempLocation
The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 5;- Parameters:
value- The tempLocation to set.- Returns:
- This builder for chaining.
-
clearTempLocation
The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 5;- Returns:
- This builder for chaining.
-
setTempLocationBytes
public FlexTemplateRuntimeEnvironment.Builder setTempLocationBytes(com.google.protobuf.ByteString value) The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 5;- Parameters:
value- The bytes for tempLocation to set.- Returns:
- This builder for chaining.
-
getMachineType
The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;- Specified by:
getMachineTypein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The machineType.
-
getMachineTypeBytes
public com.google.protobuf.ByteString getMachineTypeBytes()The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;- Specified by:
getMachineTypeBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for machineType.
-
setMachineType
The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;- Parameters:
value- The machineType to set.- Returns:
- This builder for chaining.
-
clearMachineType
The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;- Returns:
- This builder for chaining.
-
setMachineTypeBytes
public FlexTemplateRuntimeEnvironment.Builder setMachineTypeBytes(com.google.protobuf.ByteString value) The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;- Parameters:
value- The bytes for machineType to set.- Returns:
- This builder for chaining.
-
getAdditionalExperimentsList
public com.google.protobuf.ProtocolStringList getAdditionalExperimentsList()Additional experiment flags for the job.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsListin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- A list containing the additionalExperiments.
-
getAdditionalExperimentsCount
public int getAdditionalExperimentsCount()Additional experiment flags for the job.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsCountin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The count of additionalExperiments.
-
getAdditionalExperiments
Additional experiment flags for the job.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The additionalExperiments at the given index.
-
getAdditionalExperimentsBytes
public com.google.protobuf.ByteString getAdditionalExperimentsBytes(int index) Additional experiment flags for the job.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the value to return.- Returns:
- The bytes of the additionalExperiments at the given index.
-
setAdditionalExperiments
Additional experiment flags for the job.
repeated string additional_experiments = 7;- Parameters:
index- The index to set the value at.value- The additionalExperiments to set.- Returns:
- This builder for chaining.
-
addAdditionalExperiments
Additional experiment flags for the job.
repeated string additional_experiments = 7;- Parameters:
value- The additionalExperiments to add.- Returns:
- This builder for chaining.
-
addAllAdditionalExperiments
Additional experiment flags for the job.
repeated string additional_experiments = 7;- Parameters:
values- The additionalExperiments to add.- Returns:
- This builder for chaining.
-
clearAdditionalExperiments
Additional experiment flags for the job.
repeated string additional_experiments = 7;- Returns:
- This builder for chaining.
-
addAdditionalExperimentsBytes
public FlexTemplateRuntimeEnvironment.Builder addAdditionalExperimentsBytes(com.google.protobuf.ByteString value) Additional experiment flags for the job.
repeated string additional_experiments = 7;- Parameters:
value- The bytes of the additionalExperiments to add.- Returns:
- This builder for chaining.
-
getNetwork
Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Specified by:
getNetworkin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The network.
-
getNetworkBytes
public com.google.protobuf.ByteString getNetworkBytes()Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Specified by:
getNetworkBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for network.
-
setNetwork
Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Parameters:
value- The network to set.- Returns:
- This builder for chaining.
-
clearNetwork
Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Returns:
- This builder for chaining.
-
setNetworkBytes
Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Parameters:
value- The bytes for network to set.- Returns:
- This builder for chaining.
-
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;- Specified by:
getSubnetworkin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The subnetwork.
-
getSubnetworkBytes
public com.google.protobuf.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;- Specified by:
getSubnetworkBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for subnetwork.
-
setSubnetwork
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;- Parameters:
value- The subnetwork to set.- Returns:
- This builder for chaining.
-
clearSubnetwork
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;- Returns:
- This builder for chaining.
-
setSubnetworkBytes
public FlexTemplateRuntimeEnvironment.Builder setSubnetworkBytes(com.google.protobuf.ByteString value) 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;- Parameters:
value- The bytes for subnetwork to set.- Returns:
- This builder for chaining.
-
getAdditionalUserLabelsCount
public int getAdditionalUserLabelsCount()Description copied from interface:FlexTemplateRuntimeEnvironmentOrBuilderAdditional 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;- Specified by:
getAdditionalUserLabelsCountin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
containsAdditionalUserLabels
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;- Specified by:
containsAdditionalUserLabelsin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabels
Deprecated.UsegetAdditionalUserLabelsMap()instead.- Specified by:
getAdditionalUserLabelsin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
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;- Specified by:
getAdditionalUserLabelsMapin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsOrDefault
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;- Specified by:
getAdditionalUserLabelsOrDefaultin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsOrThrow
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;- Specified by:
getAdditionalUserLabelsOrThrowin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
clearAdditionalUserLabels
-
removeAdditionalUserLabels
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; -
getMutableAdditionalUserLabels
Deprecated.Use alternate mutation accessors instead. -
putAdditionalUserLabels
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; -
putAllAdditionalUserLabels
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; -
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;- Specified by:
getKmsKeyNamein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The kmsKeyName.
-
getKmsKeyNameBytes
public com.google.protobuf.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 = 11;- Specified by:
getKmsKeyNameBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for kmsKeyName.
-
setKmsKeyName
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;- Parameters:
value- The kmsKeyName to set.- Returns:
- This builder for chaining.
-
clearKmsKeyName
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;- Returns:
- This builder for chaining.
-
setKmsKeyNameBytes
public FlexTemplateRuntimeEnvironment.Builder setKmsKeyNameBytes(com.google.protobuf.ByteString value) 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;- Parameters:
value- The bytes for kmsKeyName to set.- Returns:
- This builder for chaining.
-
getIpConfigurationValue
public int getIpConfigurationValue()Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;- Specified by:
getIpConfigurationValuein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for ipConfiguration.
-
setIpConfigurationValue
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;- Parameters:
value- The enum numeric value on the wire for ipConfiguration to set.- Returns:
- This builder for chaining.
-
getIpConfiguration
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;- Specified by:
getIpConfigurationin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The ipConfiguration.
-
setIpConfiguration
public FlexTemplateRuntimeEnvironment.Builder setIpConfiguration(WorkerIPAddressConfiguration value) Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;- Parameters:
value- The ipConfiguration to set.- Returns:
- This builder for chaining.
-
clearIpConfiguration
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;- Returns:
- This builder for chaining.
-
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;- Specified by:
getWorkerRegionin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The workerRegion.
-
getWorkerRegionBytes
public com.google.protobuf.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 = 13;- Specified by:
getWorkerRegionBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for workerRegion.
-
setWorkerRegion
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;- Parameters:
value- The workerRegion to set.- Returns:
- This builder for chaining.
-
clearWorkerRegion
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;- Returns:
- This builder for chaining.
-
setWorkerRegionBytes
public FlexTemplateRuntimeEnvironment.Builder setWorkerRegionBytes(com.google.protobuf.ByteString value) 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;- Parameters:
value- The bytes for workerRegion to set.- Returns:
- This builder for chaining.
-
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;- Specified by:
getWorkerZonein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The workerZone.
-
getWorkerZoneBytes
public com.google.protobuf.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 = 14;- Specified by:
getWorkerZoneBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for workerZone.
-
setWorkerZone
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;- Parameters:
value- The workerZone to set.- Returns:
- This builder for chaining.
-
clearWorkerZone
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;- Returns:
- This builder for chaining.
-
setWorkerZoneBytes
public FlexTemplateRuntimeEnvironment.Builder setWorkerZoneBytes(com.google.protobuf.ByteString value) 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;- Parameters:
value- The bytes for workerZone to set.- Returns:
- This builder for chaining.
-
getEnableStreamingEngine
public boolean getEnableStreamingEngine()Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 15;- Specified by:
getEnableStreamingEnginein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The enableStreamingEngine.
-
setEnableStreamingEngine
Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 15;- Parameters:
value- The enableStreamingEngine to set.- Returns:
- This builder for chaining.
-
clearEnableStreamingEngine
Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 15;- Returns:
- This builder for chaining.
-
getFlexrsGoalValue
public int getFlexrsGoalValue()Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;- Specified by:
getFlexrsGoalValuein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for flexrsGoal.
-
setFlexrsGoalValue
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;- Parameters:
value- The enum numeric value on the wire for flexrsGoal to set.- Returns:
- This builder for chaining.
-
getFlexrsGoal
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;- Specified by:
getFlexrsGoalin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The flexrsGoal.
-
setFlexrsGoal
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;- Parameters:
value- The flexrsGoal to set.- Returns:
- This builder for chaining.
-
clearFlexrsGoal
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;- Returns:
- This builder for chaining.
-
getStagingLocation
The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;- Specified by:
getStagingLocationin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The stagingLocation.
-
getStagingLocationBytes
public com.google.protobuf.ByteString getStagingLocationBytes()The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;- Specified by:
getStagingLocationBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for stagingLocation.
-
setStagingLocation
The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;- Parameters:
value- The stagingLocation to set.- Returns:
- This builder for chaining.
-
clearStagingLocation
The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;- Returns:
- This builder for chaining.
-
setStagingLocationBytes
public FlexTemplateRuntimeEnvironment.Builder setStagingLocationBytes(com.google.protobuf.ByteString value) The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;- Parameters:
value- The bytes for stagingLocation to set.- Returns:
- This builder for chaining.
-
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;- Specified by:
getSdkContainerImagein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The sdkContainerImage.
-
getSdkContainerImageBytes
public com.google.protobuf.ByteString getSdkContainerImageBytes()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;- Specified by:
getSdkContainerImageBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for sdkContainerImage.
-
setSdkContainerImage
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;- Parameters:
value- The sdkContainerImage to set.- Returns:
- This builder for chaining.
-
clearSdkContainerImage
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;- Returns:
- This builder for chaining.
-
setSdkContainerImageBytes
public FlexTemplateRuntimeEnvironment.Builder setSdkContainerImageBytes(com.google.protobuf.ByteString value) 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;- Parameters:
value- The bytes for sdkContainerImage to set.- Returns:
- This builder for chaining.
-
getDiskSizeGb
public int getDiskSizeGb()Worker disk size, in gigabytes.
int32 disk_size_gb = 20;- Specified by:
getDiskSizeGbin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The diskSizeGb.
-
setDiskSizeGb
Worker disk size, in gigabytes.
int32 disk_size_gb = 20;- Parameters:
value- The diskSizeGb to set.- Returns:
- This builder for chaining.
-
clearDiskSizeGb
Worker disk size, in gigabytes.
int32 disk_size_gb = 20;- Returns:
- This builder for chaining.
-
getAutoscalingAlgorithmValue
public int getAutoscalingAlgorithmValue()The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;- Specified by:
getAutoscalingAlgorithmValuein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for autoscalingAlgorithm.
-
setAutoscalingAlgorithmValue
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;- Parameters:
value- The enum numeric value on the wire for autoscalingAlgorithm to set.- Returns:
- This builder for chaining.
-
getAutoscalingAlgorithm
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;- Specified by:
getAutoscalingAlgorithmin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The autoscalingAlgorithm.
-
setAutoscalingAlgorithm
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;- Parameters:
value- The autoscalingAlgorithm to set.- Returns:
- This builder for chaining.
-
clearAutoscalingAlgorithm
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;- Returns:
- This builder for chaining.
-
getDumpHeapOnOom
public boolean getDumpHeapOnOom()If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process. If false, ends the thread or process without saving a heap dump. Does not save a heap dump when the Java Virtual Machine (JVM) has an out of memory error during processing. The location of the heap file is either echoed back to the user, or the user is given the opportunity to download the heap file.
bool dump_heap_on_oom = 22;- Specified by:
getDumpHeapOnOomin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The dumpHeapOnOom.
-
setDumpHeapOnOom
If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process. If false, ends the thread or process without saving a heap dump. Does not save a heap dump when the Java Virtual Machine (JVM) has an out of memory error during processing. The location of the heap file is either echoed back to the user, or the user is given the opportunity to download the heap file.
bool dump_heap_on_oom = 22;- Parameters:
value- The dumpHeapOnOom to set.- Returns:
- This builder for chaining.
-
clearDumpHeapOnOom
If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process. If false, ends the thread or process without saving a heap dump. Does not save a heap dump when the Java Virtual Machine (JVM) has an out of memory error during processing. The location of the heap file is either echoed back to the user, or the user is given the opportunity to download the heap file.
bool dump_heap_on_oom = 22;- Returns:
- This builder for chaining.
-
getSaveHeapDumpsToGcsPath
Cloud Storage bucket (directory) to upload heap dumps to. Enabling this field implies that `dump_heap_on_oom` is set to true.
string save_heap_dumps_to_gcs_path = 23;- Specified by:
getSaveHeapDumpsToGcsPathin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The saveHeapDumpsToGcsPath.
-
getSaveHeapDumpsToGcsPathBytes
public com.google.protobuf.ByteString getSaveHeapDumpsToGcsPathBytes()Cloud Storage bucket (directory) to upload heap dumps to. Enabling this field implies that `dump_heap_on_oom` is set to true.
string save_heap_dumps_to_gcs_path = 23;- Specified by:
getSaveHeapDumpsToGcsPathBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for saveHeapDumpsToGcsPath.
-
setSaveHeapDumpsToGcsPath
Cloud Storage bucket (directory) to upload heap dumps to. Enabling this field implies that `dump_heap_on_oom` is set to true.
string save_heap_dumps_to_gcs_path = 23;- Parameters:
value- The saveHeapDumpsToGcsPath to set.- Returns:
- This builder for chaining.
-
clearSaveHeapDumpsToGcsPath
Cloud Storage bucket (directory) to upload heap dumps to. Enabling this field implies that `dump_heap_on_oom` is set to true.
string save_heap_dumps_to_gcs_path = 23;- Returns:
- This builder for chaining.
-
setSaveHeapDumpsToGcsPathBytes
public FlexTemplateRuntimeEnvironment.Builder setSaveHeapDumpsToGcsPathBytes(com.google.protobuf.ByteString value) Cloud Storage bucket (directory) to upload heap dumps to. Enabling this field implies that `dump_heap_on_oom` is set to true.
string save_heap_dumps_to_gcs_path = 23;- Parameters:
value- The bytes for saveHeapDumpsToGcsPath to set.- Returns:
- This builder for chaining.
-
getLauncherMachineType
The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;- Specified by:
getLauncherMachineTypein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The launcherMachineType.
-
getLauncherMachineTypeBytes
public com.google.protobuf.ByteString getLauncherMachineTypeBytes()The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;- Specified by:
getLauncherMachineTypeBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for launcherMachineType.
-
setLauncherMachineType
The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;- Parameters:
value- The launcherMachineType to set.- Returns:
- This builder for chaining.
-
clearLauncherMachineType
The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;- Returns:
- This builder for chaining.
-
setLauncherMachineTypeBytes
public FlexTemplateRuntimeEnvironment.Builder setLauncherMachineTypeBytes(com.google.protobuf.ByteString value) The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;- Parameters:
value- The bytes for launcherMachineType to set.- Returns:
- This builder for chaining.
-
getEnableLauncherVmSerialPortLogging
public boolean getEnableLauncherVmSerialPortLogging()If true serial port logging will be enabled for the launcher VM.
bool enable_launcher_vm_serial_port_logging = 25;- Specified by:
getEnableLauncherVmSerialPortLoggingin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The enableLauncherVmSerialPortLogging.
-
setEnableLauncherVmSerialPortLogging
If true serial port logging will be enabled for the launcher VM.
bool enable_launcher_vm_serial_port_logging = 25;- Parameters:
value- The enableLauncherVmSerialPortLogging to set.- Returns:
- This builder for chaining.
-
clearEnableLauncherVmSerialPortLogging
If true serial port logging will be enabled for the launcher VM.
bool enable_launcher_vm_serial_port_logging = 25;- Returns:
- This builder for chaining.
-
hasStreamingMode
public boolean hasStreamingMode()Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
hasStreamingModein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- Whether the streamingMode field is set.
-
getStreamingModeValue
public int getStreamingModeValue()Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getStreamingModeValuein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for streamingMode.
-
setStreamingModeValue
Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];- Parameters:
value- The enum numeric value on the wire for streamingMode to set.- Returns:
- This builder for chaining.
-
getStreamingMode
Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getStreamingModein interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The streamingMode.
-
setStreamingMode
Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];- Parameters:
value- The streamingMode to set.- Returns:
- This builder for chaining.
-
clearStreamingMode
Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 26 [(.google.api.field_behavior) = OPTIONAL];- Returns:
- This builder for chaining.
-
getAdditionalPipelineOptionsList
public com.google.protobuf.ProtocolStringList getAdditionalPipelineOptionsList()Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsListin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- A list containing the additionalPipelineOptions.
-
getAdditionalPipelineOptionsCount
public int getAdditionalPipelineOptionsCount()Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsCountin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The count of additionalPipelineOptions.
-
getAdditionalPipelineOptions
Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The additionalPipelineOptions at the given index.
-
getAdditionalPipelineOptionsBytes
public com.google.protobuf.ByteString getAdditionalPipelineOptionsBytes(int index) Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the value to return.- Returns:
- The bytes of the additionalPipelineOptions at the given index.
-
setAdditionalPipelineOptions
Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Parameters:
index- The index to set the value at.value- The additionalPipelineOptions to set.- Returns:
- This builder for chaining.
-
addAdditionalPipelineOptions
Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Parameters:
value- The additionalPipelineOptions to add.- Returns:
- This builder for chaining.
-
addAllAdditionalPipelineOptions
public FlexTemplateRuntimeEnvironment.Builder addAllAdditionalPipelineOptions(Iterable<String> values) Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Parameters:
values- The additionalPipelineOptions to add.- Returns:
- This builder for chaining.
-
clearAdditionalPipelineOptions
Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Returns:
- This builder for chaining.
-
addAdditionalPipelineOptionsBytes
public FlexTemplateRuntimeEnvironment.Builder addAdditionalPipelineOptionsBytes(com.google.protobuf.ByteString value) Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 27 [(.google.api.field_behavior) = OPTIONAL];- Parameters:
value- The bytes of the additionalPipelineOptions to add.- Returns:
- This builder for chaining.
-