additionalUserLabels__ =
input.readMessage(
AdditionalUserLabelsDefaultEntryHolder.defaultEntry.getParserForType(),
extensionRegistry);
internalGetMutableAdditionalUserLabels()
.getMutableMap()
.put(additionalUserLabels__.getKey(), additionalUserLabels__.getValue());
bitField0_ |= 0x00000400;
break;
} // case 82
case 88:
{
numWorkers_ = input.readInt32();
bitField0_ |= 0x00000001;
break;
} // case 88
case 98:
{
kmsKeyName_ = input.readStringRequireUtf8();
bitField0_ |= 0x00000800;
break;
} // case 98
case 112:
{
ipConfiguration_ = input.readEnum();
bitField0_ |= 0x00001000;
break;
} // case 112
case 122:
{
workerRegion_ = input.readStringRequireUtf8();
bitField0_ |= 0x00002000;
break;
} // case 122
case 130:
{
workerZone_ = input.readStringRequireUtf8();
bitField0_ |= 0x00004000;
break;
} // case 130
case 136:
{
enableStreamingEngine_ = input.readBool();
bitField0_ |= 0x00008000;
break;
} // case 136
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
done = true; // was an endgroup tag
}
break;
} // default:
} // switch (tag)
} // while (!done)
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.unwrapIOException();
} finally {
onChanged();
} // finally
return this;
}
private int bitField0_;
private int numWorkers_;
/**
*
*
*
* The initial number of Google Compute Engine instnaces for the job.
*
*
* int32 num_workers = 11;
*
* @return The numWorkers.
*/
@java.lang.Override
public int getNumWorkers() {
return numWorkers_;
}
/**
*
*
*
* The initial number of Google Compute Engine instnaces for the job.
*
*
* int32 num_workers = 11;
*
* @param value The numWorkers to set.
* @return This builder for chaining.
*/
public Builder setNumWorkers(int value) {
numWorkers_ = value;
bitField0_ |= 0x00000001;
onChanged();
return this;
}
/**
*
*
*
* The initial number of Google Compute Engine instnaces for the job.
*
*
* int32 num_workers = 11;
*
* @return This builder for chaining.
*/
public Builder clearNumWorkers() {
bitField0_ = (bitField0_ & ~0x00000001);
numWorkers_ = 0;
onChanged();
return this;
}
private int maxWorkers_;
/**
*
*
*
* 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;
*
* @return The maxWorkers.
*/
@java.lang.Override
public int getMaxWorkers() {
return maxWorkers_;
}
/**
*
*
*
* 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;
*
* @param value The maxWorkers to set.
* @return This builder for chaining.
*/
public Builder setMaxWorkers(int value) {
maxWorkers_ = value;
bitField0_ |= 0x00000002;
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @return This builder for chaining.
*/
public Builder clearMaxWorkers() {
bitField0_ = (bitField0_ & ~0x00000002);
maxWorkers_ = 0;
onChanged();
return this;
}
private java.lang.Object zone_ = "";
/**
*
*
*
* 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 = 2;
*
* @return The zone.
*/
public java.lang.String getZone() {
java.lang.Object ref = zone_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
zone_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* 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 = 2;
*
* @return The bytes for zone.
*/
public com.google.protobuf.ByteString getZoneBytes() {
java.lang.Object ref = zone_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
zone_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* 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 = 2;
*
* @param value The zone to set.
* @return This builder for chaining.
*/
public Builder setZone(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
zone_ = value;
bitField0_ |= 0x00000004;
onChanged();
return this;
}
/**
*
*
*
* 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 = 2;
*
* @return This builder for chaining.
*/
public Builder clearZone() {
zone_ = getDefaultInstance().getZone();
bitField0_ = (bitField0_ & ~0x00000004);
onChanged();
return this;
}
/**
*
*
*
* 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 = 2;
*
* @param value The bytes for zone to set.
* @return This builder for chaining.
*/
public Builder setZoneBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
zone_ = value;
bitField0_ |= 0x00000004;
onChanged();
return this;
}
private java.lang.Object serviceAccountEmail_ = "";
/**
*
*
*
* The email address of the service account to run the job as.
*
*
* string service_account_email = 3;
*
* @return The serviceAccountEmail.
*/
public java.lang.String getServiceAccountEmail() {
java.lang.Object ref = serviceAccountEmail_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
serviceAccountEmail_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* The email address of the service account to run the job as.
*
*
* string service_account_email = 3;
*
* @return The bytes for serviceAccountEmail.
*/
public com.google.protobuf.ByteString getServiceAccountEmailBytes() {
java.lang.Object ref = serviceAccountEmail_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
serviceAccountEmail_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* The email address of the service account to run the job as.
*
*
* string service_account_email = 3;
*
* @param value The serviceAccountEmail to set.
* @return This builder for chaining.
*/
public Builder setServiceAccountEmail(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
serviceAccountEmail_ = value;
bitField0_ |= 0x00000008;
onChanged();
return this;
}
/**
*
*
*
* The email address of the service account to run the job as.
*
*
* string service_account_email = 3;
*
* @return This builder for chaining.
*/
public Builder clearServiceAccountEmail() {
serviceAccountEmail_ = getDefaultInstance().getServiceAccountEmail();
bitField0_ = (bitField0_ & ~0x00000008);
onChanged();
return this;
}
/**
*
*
*
* The email address of the service account to run the job as.
*
*
* string service_account_email = 3;
*
* @param value The bytes for serviceAccountEmail to set.
* @return This builder for chaining.
*/
public Builder setServiceAccountEmailBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
serviceAccountEmail_ = value;
bitField0_ |= 0x00000008;
onChanged();
return this;
}
private java.lang.Object tempLocation_ = "";
/**
*
*
*
* The Cloud Storage path to use for temporary files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string temp_location = 4;
*
* @return The tempLocation.
*/
public java.lang.String getTempLocation() {
java.lang.Object ref = tempLocation_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
tempLocation_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* The Cloud Storage path to use for temporary files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string temp_location = 4;
*
* @return The bytes for tempLocation.
*/
public com.google.protobuf.ByteString getTempLocationBytes() {
java.lang.Object ref = tempLocation_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
tempLocation_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* The Cloud Storage path to use for temporary files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string temp_location = 4;
*
* @param value The tempLocation to set.
* @return This builder for chaining.
*/
public Builder setTempLocation(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
tempLocation_ = value;
bitField0_ |= 0x00000010;
onChanged();
return this;
}
/**
*
*
*
* The Cloud Storage path to use for temporary files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string temp_location = 4;
*
* @return This builder for chaining.
*/
public Builder clearTempLocation() {
tempLocation_ = getDefaultInstance().getTempLocation();
bitField0_ = (bitField0_ & ~0x00000010);
onChanged();
return this;
}
/**
*
*
*
* The Cloud Storage path to use for temporary files.
* Must be a valid Cloud Storage URL, beginning with `gs://`.
*
*
* string temp_location = 4;
*
* @param value The bytes for tempLocation to set.
* @return This builder for chaining.
*/
public Builder setTempLocationBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
tempLocation_ = value;
bitField0_ |= 0x00000010;
onChanged();
return this;
}
private boolean bypassTempDirValidation_;
/**
*
*
*
* Whether to bypass the safety checks for the job's temporary directory.
* Use with caution.
*
*
* bool bypass_temp_dir_validation = 5;
*
* @return The bypassTempDirValidation.
*/
@java.lang.Override
public boolean getBypassTempDirValidation() {
return bypassTempDirValidation_;
}
/**
*
*
*
* Whether to bypass the safety checks for the job's temporary directory.
* Use with caution.
*
*
* bool bypass_temp_dir_validation = 5;
*
* @param value The bypassTempDirValidation to set.
* @return This builder for chaining.
*/
public Builder setBypassTempDirValidation(boolean value) {
bypassTempDirValidation_ = value;
bitField0_ |= 0x00000020;
onChanged();
return this;
}
/**
*
*
*
* Whether to bypass the safety checks for the job's temporary directory.
* Use with caution.
*
*
* bool bypass_temp_dir_validation = 5;
*
* @return This builder for chaining.
*/
public Builder clearBypassTempDirValidation() {
bitField0_ = (bitField0_ & ~0x00000020);
bypassTempDirValidation_ = false;
onChanged();
return this;
}
private java.lang.Object machineType_ = "";
/**
*
*
*
* The machine type to use for the job. Defaults to the value from the
* template if not specified.
*
*
* string machine_type = 6;
*
* @return The machineType.
*/
public java.lang.String getMachineType() {
java.lang.Object ref = machineType_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
machineType_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* The machine type to use for the job. Defaults to the value from the
* template if not specified.
*
*
* string machine_type = 6;
*
* @return The bytes for machineType.
*/
public com.google.protobuf.ByteString getMachineTypeBytes() {
java.lang.Object ref = machineType_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
machineType_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* The machine type to use for the job. Defaults to the value from the
* template if not specified.
*
*
* string machine_type = 6;
*
* @param value The machineType to set.
* @return This builder for chaining.
*/
public Builder setMachineType(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
machineType_ = value;
bitField0_ |= 0x00000040;
onChanged();
return this;
}
/**
*
*
*
* The machine type to use for the job. Defaults to the value from the
* template if not specified.
*
*
* string machine_type = 6;
*
* @return This builder for chaining.
*/
public Builder clearMachineType() {
machineType_ = getDefaultInstance().getMachineType();
bitField0_ = (bitField0_ & ~0x00000040);
onChanged();
return this;
}
/**
*
*
*
* The machine type to use for the job. Defaults to the value from the
* template if not specified.
*
*
* string machine_type = 6;
*
* @param value The bytes for machineType to set.
* @return This builder for chaining.
*/
public Builder setMachineTypeBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
machineType_ = value;
bitField0_ |= 0x00000040;
onChanged();
return this;
}
private com.google.protobuf.LazyStringList additionalExperiments_ =
com.google.protobuf.LazyStringArrayList.EMPTY;
private void ensureAdditionalExperimentsIsMutable() {
if (!((bitField0_ & 0x00000080) != 0)) {
additionalExperiments_ =
new com.google.protobuf.LazyStringArrayList(additionalExperiments_);
bitField0_ |= 0x00000080;
}
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @return A list containing the additionalExperiments.
*/
public com.google.protobuf.ProtocolStringList getAdditionalExperimentsList() {
return additionalExperiments_.getUnmodifiableView();
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @return The count of additionalExperiments.
*/
public int getAdditionalExperimentsCount() {
return additionalExperiments_.size();
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @param index The index of the element to return.
* @return The additionalExperiments at the given index.
*/
public java.lang.String getAdditionalExperiments(int index) {
return additionalExperiments_.get(index);
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @param index The index of the value to return.
* @return The bytes of the additionalExperiments at the given index.
*/
public com.google.protobuf.ByteString getAdditionalExperimentsBytes(int index) {
return additionalExperiments_.getByteString(index);
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @param index The index to set the value at.
* @param value The additionalExperiments to set.
* @return This builder for chaining.
*/
public Builder setAdditionalExperiments(int index, java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
ensureAdditionalExperimentsIsMutable();
additionalExperiments_.set(index, value);
onChanged();
return this;
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @param value The additionalExperiments to add.
* @return This builder for chaining.
*/
public Builder addAdditionalExperiments(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
ensureAdditionalExperimentsIsMutable();
additionalExperiments_.add(value);
onChanged();
return this;
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @param values The additionalExperiments to add.
* @return This builder for chaining.
*/
public Builder addAllAdditionalExperiments(java.lang.Iterable values) {
ensureAdditionalExperimentsIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(values, additionalExperiments_);
onChanged();
return this;
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @return This builder for chaining.
*/
public Builder clearAdditionalExperiments() {
additionalExperiments_ = com.google.protobuf.LazyStringArrayList.EMPTY;
bitField0_ = (bitField0_ & ~0x00000080);
onChanged();
return this;
}
/**
*
*
*
* Additional experiment flags for the job, specified with the
* `--experiments` option.
*
*
* repeated string additional_experiments = 7;
*
* @param value The bytes of the additionalExperiments to add.
* @return This builder for chaining.
*/
public Builder addAdditionalExperimentsBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
ensureAdditionalExperimentsIsMutable();
additionalExperiments_.add(value);
onChanged();
return this;
}
private java.lang.Object network_ = "";
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 8;
*
* @return The network.
*/
public java.lang.String getNetwork() {
java.lang.Object ref = network_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
network_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 8;
*
* @return The bytes for network.
*/
public com.google.protobuf.ByteString getNetworkBytes() {
java.lang.Object ref = network_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
network_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 8;
*
* @param value The network to set.
* @return This builder for chaining.
*/
public Builder setNetwork(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
network_ = value;
bitField0_ |= 0x00000100;
onChanged();
return this;
}
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 8;
*
* @return This builder for chaining.
*/
public Builder clearNetwork() {
network_ = getDefaultInstance().getNetwork();
bitField0_ = (bitField0_ & ~0x00000100);
onChanged();
return this;
}
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 8;
*
* @param value The bytes for network to set.
* @return This builder for chaining.
*/
public Builder setNetworkBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
network_ = value;
bitField0_ |= 0x00000100;
onChanged();
return this;
}
private java.lang.Object subnetwork_ = "";
/**
*
*
*
* 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;
*
* @return The subnetwork.
*/
public java.lang.String getSubnetwork() {
java.lang.Object ref = subnetwork_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
subnetwork_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* 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;
*
* @return The bytes for subnetwork.
*/
public com.google.protobuf.ByteString getSubnetworkBytes() {
java.lang.Object ref = subnetwork_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
subnetwork_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* 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;
*
* @param value The subnetwork to set.
* @return This builder for chaining.
*/
public Builder setSubnetwork(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
subnetwork_ = value;
bitField0_ |= 0x00000200;
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @return This builder for chaining.
*/
public Builder clearSubnetwork() {
subnetwork_ = getDefaultInstance().getSubnetwork();
bitField0_ = (bitField0_ & ~0x00000200);
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @param value The bytes for subnetwork to set.
* @return This builder for chaining.
*/
public Builder setSubnetworkBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
subnetwork_ = value;
bitField0_ |= 0x00000200;
onChanged();
return this;
}
private com.google.protobuf.MapField additionalUserLabels_;
private com.google.protobuf.MapField
internalGetAdditionalUserLabels() {
if (additionalUserLabels_ == null) {
return com.google.protobuf.MapField.emptyMapField(
AdditionalUserLabelsDefaultEntryHolder.defaultEntry);
}
return additionalUserLabels_;
}
private com.google.protobuf.MapField
internalGetMutableAdditionalUserLabels() {
if (additionalUserLabels_ == null) {
additionalUserLabels_ =
com.google.protobuf.MapField.newMapField(
AdditionalUserLabelsDefaultEntryHolder.defaultEntry);
}
if (!additionalUserLabels_.isMutable()) {
additionalUserLabels_ = additionalUserLabels_.copy();
}
bitField0_ |= 0x00000400;
onChanged();
return additionalUserLabels_;
}
public int getAdditionalUserLabelsCount() {
return internalGetAdditionalUserLabels().getMap().size();
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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.Override
public boolean containsAdditionalUserLabels(java.lang.String key) {
if (key == null) {
throw new NullPointerException("map key");
}
return internalGetAdditionalUserLabels().getMap().containsKey(key);
}
/** Use {@link #getAdditionalUserLabelsMap()} instead. */
@java.lang.Override
@java.lang.Deprecated
public java.util.Map getAdditionalUserLabels() {
return getAdditionalUserLabelsMap();
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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.Override
public java.util.Map getAdditionalUserLabelsMap() {
return internalGetAdditionalUserLabels().getMap();
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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.Override
public /* nullable */ java.lang.String getAdditionalUserLabelsOrDefault(
java.lang.String key,
/* nullable */
java.lang.String defaultValue) {
if (key == null) {
throw new NullPointerException("map key");
}
java.util.Map map =
internalGetAdditionalUserLabels().getMap();
return map.containsKey(key) ? map.get(key) : defaultValue;
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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.Override
public java.lang.String getAdditionalUserLabelsOrThrow(java.lang.String key) {
if (key == null) {
throw new NullPointerException("map key");
}
java.util.Map map =
internalGetAdditionalUserLabels().getMap();
if (!map.containsKey(key)) {
throw new java.lang.IllegalArgumentException();
}
return map.get(key);
}
public Builder clearAdditionalUserLabels() {
bitField0_ = (bitField0_ & ~0x00000400);
internalGetMutableAdditionalUserLabels().getMutableMap().clear();
return this;
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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;
*/
public Builder removeAdditionalUserLabels(java.lang.String key) {
if (key == null) {
throw new NullPointerException("map key");
}
internalGetMutableAdditionalUserLabels().getMutableMap().remove(key);
return this;
}
/** Use alternate mutation accessors instead. */
@java.lang.Deprecated
public java.util.Map getMutableAdditionalUserLabels() {
bitField0_ |= 0x00000400;
return internalGetMutableAdditionalUserLabels().getMutableMap();
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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;
*/
public Builder putAdditionalUserLabels(java.lang.String key, java.lang.String value) {
if (key == null) {
throw new NullPointerException("map key");
}
if (value == null) {
throw new NullPointerException("map value");
}
internalGetMutableAdditionalUserLabels().getMutableMap().put(key, value);
bitField0_ |= 0x00000400;
return this;
}
/**
*
*
*
* Additional user labels to be specified for the job.
* Keys and values should 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;
*/
public Builder putAllAdditionalUserLabels(
java.util.Map values) {
internalGetMutableAdditionalUserLabels().getMutableMap().putAll(values);
bitField0_ |= 0x00000400;
return this;
}
private java.lang.Object kmsKeyName_ = "";
/**
*
*
*
* 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;
*
* @return The kmsKeyName.
*/
public java.lang.String getKmsKeyName() {
java.lang.Object ref = kmsKeyName_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
kmsKeyName_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* 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;
*
* @return The bytes for kmsKeyName.
*/
public com.google.protobuf.ByteString getKmsKeyNameBytes() {
java.lang.Object ref = kmsKeyName_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
kmsKeyName_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* 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;
*
* @param value The kmsKeyName to set.
* @return This builder for chaining.
*/
public Builder setKmsKeyName(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
kmsKeyName_ = value;
bitField0_ |= 0x00000800;
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @return This builder for chaining.
*/
public Builder clearKmsKeyName() {
kmsKeyName_ = getDefaultInstance().getKmsKeyName();
bitField0_ = (bitField0_ & ~0x00000800);
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @param value The bytes for kmsKeyName to set.
* @return This builder for chaining.
*/
public Builder setKmsKeyNameBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
kmsKeyName_ = value;
bitField0_ |= 0x00000800;
onChanged();
return this;
}
private int ipConfiguration_ = 0;
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
*
* @return The enum numeric value on the wire for ipConfiguration.
*/
@java.lang.Override
public int getIpConfigurationValue() {
return ipConfiguration_;
}
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
*
* @param value The enum numeric value on the wire for ipConfiguration to set.
* @return This builder for chaining.
*/
public Builder setIpConfigurationValue(int value) {
ipConfiguration_ = value;
bitField0_ |= 0x00001000;
onChanged();
return this;
}
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
*
* @return The ipConfiguration.
*/
@java.lang.Override
public com.google.dataflow.v1beta3.WorkerIPAddressConfiguration getIpConfiguration() {
com.google.dataflow.v1beta3.WorkerIPAddressConfiguration result =
com.google.dataflow.v1beta3.WorkerIPAddressConfiguration.forNumber(ipConfiguration_);
return result == null
? com.google.dataflow.v1beta3.WorkerIPAddressConfiguration.UNRECOGNIZED
: result;
}
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
*
* @param value The ipConfiguration to set.
* @return This builder for chaining.
*/
public Builder setIpConfiguration(
com.google.dataflow.v1beta3.WorkerIPAddressConfiguration value) {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00001000;
ipConfiguration_ = value.getNumber();
onChanged();
return this;
}
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
*
* @return This builder for chaining.
*/
public Builder clearIpConfiguration() {
bitField0_ = (bitField0_ & ~0x00001000);
ipConfiguration_ = 0;
onChanged();
return this;
}
private java.lang.Object workerRegion_ = "";
/**
*
*
*
* 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;
*
* @return The workerRegion.
*/
public java.lang.String getWorkerRegion() {
java.lang.Object ref = workerRegion_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
workerRegion_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* 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;
*
* @return The bytes for workerRegion.
*/
public com.google.protobuf.ByteString getWorkerRegionBytes() {
java.lang.Object ref = workerRegion_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
workerRegion_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* 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;
*
* @param value The workerRegion to set.
* @return This builder for chaining.
*/
public Builder setWorkerRegion(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
workerRegion_ = value;
bitField0_ |= 0x00002000;
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @return This builder for chaining.
*/
public Builder clearWorkerRegion() {
workerRegion_ = getDefaultInstance().getWorkerRegion();
bitField0_ = (bitField0_ & ~0x00002000);
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @param value The bytes for workerRegion to set.
* @return This builder for chaining.
*/
public Builder setWorkerRegionBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
workerRegion_ = value;
bitField0_ |= 0x00002000;
onChanged();
return this;
}
private java.lang.Object workerZone_ = "";
/**
*
*
*
* 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;
*
* @return The workerZone.
*/
public java.lang.String getWorkerZone() {
java.lang.Object ref = workerZone_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
workerZone_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* 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;
*
* @return The bytes for workerZone.
*/
public com.google.protobuf.ByteString getWorkerZoneBytes() {
java.lang.Object ref = workerZone_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
workerZone_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* 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;
*
* @param value The workerZone to set.
* @return This builder for chaining.
*/
public Builder setWorkerZone(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
workerZone_ = value;
bitField0_ |= 0x00004000;
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @return This builder for chaining.
*/
public Builder clearWorkerZone() {
workerZone_ = getDefaultInstance().getWorkerZone();
bitField0_ = (bitField0_ & ~0x00004000);
onChanged();
return this;
}
/**
*
*
*
* 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;
*
* @param value The bytes for workerZone to set.
* @return This builder for chaining.
*/
public Builder setWorkerZoneBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
workerZone_ = value;
bitField0_ |= 0x00004000;
onChanged();
return this;
}
private boolean enableStreamingEngine_;
/**
*
*
*
* Whether to enable Streaming Engine for the job.
*
*
* bool enable_streaming_engine = 17;
*
* @return The enableStreamingEngine.
*/
@java.lang.Override
public boolean getEnableStreamingEngine() {
return enableStreamingEngine_;
}
/**
*
*
*
* Whether to enable Streaming Engine for the job.
*
*
* bool enable_streaming_engine = 17;
*
* @param value The enableStreamingEngine to set.
* @return This builder for chaining.
*/
public Builder setEnableStreamingEngine(boolean value) {
enableStreamingEngine_ = value;
bitField0_ |= 0x00008000;
onChanged();
return this;
}
/**
*
*
*
* Whether to enable Streaming Engine for the job.
*
*
* bool enable_streaming_engine = 17;
*
* @return This builder for chaining.
*/
public Builder clearEnableStreamingEngine() {
bitField0_ = (bitField0_ & ~0x00008000);
enableStreamingEngine_ = false;
onChanged();
return this;
}
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
}
@java.lang.Override
public final Builder mergeUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.mergeUnknownFields(unknownFields);
}
// @@protoc_insertion_point(builder_scope:google.dataflow.v1beta3.RuntimeEnvironment)
}
// @@protoc_insertion_point(class_scope:google.dataflow.v1beta3.RuntimeEnvironment)
private static final com.google.dataflow.v1beta3.RuntimeEnvironment DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.google.dataflow.v1beta3.RuntimeEnvironment();
}
public static com.google.dataflow.v1beta3.RuntimeEnvironment getDefaultInstance() {
return DEFAULT_INSTANCE;
}
private static final com.google.protobuf.Parser PARSER =
new com.google.protobuf.AbstractParser() {
@java.lang.Override
public RuntimeEnvironment parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
Builder builder = newBuilder();
try {
builder.mergeFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(builder.buildPartial());
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(e)
.setUnfinishedMessage(builder.buildPartial());
}
return builder.buildPartial();
}
};
public static com.google.protobuf.Parser parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser getParserForType() {
return PARSER;
}
@java.lang.Override
public com.google.dataflow.v1beta3.RuntimeEnvironment getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}