getPackagesBuilderList() {
return getPackagesFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.Package,
com.google.dataflow.v1beta3.Package.Builder,
com.google.dataflow.v1beta3.PackageOrBuilder>
getPackagesFieldBuilder() {
if (packagesBuilder_ == null) {
packagesBuilder_ =
new com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.Package,
com.google.dataflow.v1beta3.Package.Builder,
com.google.dataflow.v1beta3.PackageOrBuilder>(
packages_, ((bitField0_ & 0x00000004) != 0), getParentForChildren(), isClean());
packages_ = null;
}
return packagesBuilder_;
}
private int defaultPackageSet_ = 0;
/**
*
*
*
* The default package set to install. This allows the service to
* select a default set of packages which are useful to worker
* harnesses written in a particular language.
*
*
* .google.dataflow.v1beta3.DefaultPackageSet default_package_set = 4;
*
* @return The enum numeric value on the wire for defaultPackageSet.
*/
@java.lang.Override
public int getDefaultPackageSetValue() {
return defaultPackageSet_;
}
/**
*
*
*
* The default package set to install. This allows the service to
* select a default set of packages which are useful to worker
* harnesses written in a particular language.
*
*
* .google.dataflow.v1beta3.DefaultPackageSet default_package_set = 4;
*
* @param value The enum numeric value on the wire for defaultPackageSet to set.
* @return This builder for chaining.
*/
public Builder setDefaultPackageSetValue(int value) {
defaultPackageSet_ = value;
bitField0_ |= 0x00000008;
onChanged();
return this;
}
/**
*
*
*
* The default package set to install. This allows the service to
* select a default set of packages which are useful to worker
* harnesses written in a particular language.
*
*
* .google.dataflow.v1beta3.DefaultPackageSet default_package_set = 4;
*
* @return The defaultPackageSet.
*/
@java.lang.Override
public com.google.dataflow.v1beta3.DefaultPackageSet getDefaultPackageSet() {
com.google.dataflow.v1beta3.DefaultPackageSet result =
com.google.dataflow.v1beta3.DefaultPackageSet.forNumber(defaultPackageSet_);
return result == null ? com.google.dataflow.v1beta3.DefaultPackageSet.UNRECOGNIZED : result;
}
/**
*
*
*
* The default package set to install. This allows the service to
* select a default set of packages which are useful to worker
* harnesses written in a particular language.
*
*
* .google.dataflow.v1beta3.DefaultPackageSet default_package_set = 4;
*
* @param value The defaultPackageSet to set.
* @return This builder for chaining.
*/
public Builder setDefaultPackageSet(com.google.dataflow.v1beta3.DefaultPackageSet value) {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000008;
defaultPackageSet_ = value.getNumber();
onChanged();
return this;
}
/**
*
*
*
* The default package set to install. This allows the service to
* select a default set of packages which are useful to worker
* harnesses written in a particular language.
*
*
* .google.dataflow.v1beta3.DefaultPackageSet default_package_set = 4;
*
* @return This builder for chaining.
*/
public Builder clearDefaultPackageSet() {
bitField0_ = (bitField0_ & ~0x00000008);
defaultPackageSet_ = 0;
onChanged();
return this;
}
private java.lang.Object machineType_ = "";
/**
*
*
*
* Machine type (e.g. "n1-standard-1"). If empty or unspecified, the
* service will attempt to choose a reasonable default.
*
*
* string machine_type = 5;
*
* @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;
}
}
/**
*
*
*
* Machine type (e.g. "n1-standard-1"). If empty or unspecified, the
* service will attempt to choose a reasonable default.
*
*
* string machine_type = 5;
*
* @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;
}
}
/**
*
*
*
* Machine type (e.g. "n1-standard-1"). If empty or unspecified, the
* service will attempt to choose a reasonable default.
*
*
* string machine_type = 5;
*
* @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_ |= 0x00000010;
onChanged();
return this;
}
/**
*
*
*
* Machine type (e.g. "n1-standard-1"). If empty or unspecified, the
* service will attempt to choose a reasonable default.
*
*
* string machine_type = 5;
*
* @return This builder for chaining.
*/
public Builder clearMachineType() {
machineType_ = getDefaultInstance().getMachineType();
bitField0_ = (bitField0_ & ~0x00000010);
onChanged();
return this;
}
/**
*
*
*
* Machine type (e.g. "n1-standard-1"). If empty or unspecified, the
* service will attempt to choose a reasonable default.
*
*
* string machine_type = 5;
*
* @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_ |= 0x00000010;
onChanged();
return this;
}
private int teardownPolicy_ = 0;
/**
*
*
*
* Sets the policy for determining when to turndown worker pool.
* Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and
* `TEARDOWN_NEVER`.
* `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
* the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down
* if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn
* down.
* If the workers are not torn down by the service, they will
* continue to run and use Google Compute Engine VM resources in the
* user's project until they are explicitly terminated by the user.
* Because of this, Google recommends using the `TEARDOWN_ALWAYS`
* policy except for small, manually supervised test jobs.
* If unknown or unspecified, the service will attempt to choose a reasonable
* default.
*
*
* .google.dataflow.v1beta3.TeardownPolicy teardown_policy = 6;
*
* @return The enum numeric value on the wire for teardownPolicy.
*/
@java.lang.Override
public int getTeardownPolicyValue() {
return teardownPolicy_;
}
/**
*
*
*
* Sets the policy for determining when to turndown worker pool.
* Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and
* `TEARDOWN_NEVER`.
* `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
* the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down
* if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn
* down.
* If the workers are not torn down by the service, they will
* continue to run and use Google Compute Engine VM resources in the
* user's project until they are explicitly terminated by the user.
* Because of this, Google recommends using the `TEARDOWN_ALWAYS`
* policy except for small, manually supervised test jobs.
* If unknown or unspecified, the service will attempt to choose a reasonable
* default.
*
*
* .google.dataflow.v1beta3.TeardownPolicy teardown_policy = 6;
*
* @param value The enum numeric value on the wire for teardownPolicy to set.
* @return This builder for chaining.
*/
public Builder setTeardownPolicyValue(int value) {
teardownPolicy_ = value;
bitField0_ |= 0x00000020;
onChanged();
return this;
}
/**
*
*
*
* Sets the policy for determining when to turndown worker pool.
* Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and
* `TEARDOWN_NEVER`.
* `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
* the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down
* if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn
* down.
* If the workers are not torn down by the service, they will
* continue to run and use Google Compute Engine VM resources in the
* user's project until they are explicitly terminated by the user.
* Because of this, Google recommends using the `TEARDOWN_ALWAYS`
* policy except for small, manually supervised test jobs.
* If unknown or unspecified, the service will attempt to choose a reasonable
* default.
*
*
* .google.dataflow.v1beta3.TeardownPolicy teardown_policy = 6;
*
* @return The teardownPolicy.
*/
@java.lang.Override
public com.google.dataflow.v1beta3.TeardownPolicy getTeardownPolicy() {
com.google.dataflow.v1beta3.TeardownPolicy result =
com.google.dataflow.v1beta3.TeardownPolicy.forNumber(teardownPolicy_);
return result == null ? com.google.dataflow.v1beta3.TeardownPolicy.UNRECOGNIZED : result;
}
/**
*
*
*
* Sets the policy for determining when to turndown worker pool.
* Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and
* `TEARDOWN_NEVER`.
* `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
* the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down
* if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn
* down.
* If the workers are not torn down by the service, they will
* continue to run and use Google Compute Engine VM resources in the
* user's project until they are explicitly terminated by the user.
* Because of this, Google recommends using the `TEARDOWN_ALWAYS`
* policy except for small, manually supervised test jobs.
* If unknown or unspecified, the service will attempt to choose a reasonable
* default.
*
*
* .google.dataflow.v1beta3.TeardownPolicy teardown_policy = 6;
*
* @param value The teardownPolicy to set.
* @return This builder for chaining.
*/
public Builder setTeardownPolicy(com.google.dataflow.v1beta3.TeardownPolicy value) {
if (value == null) {
throw new NullPointerException();
}
bitField0_ |= 0x00000020;
teardownPolicy_ = value.getNumber();
onChanged();
return this;
}
/**
*
*
*
* Sets the policy for determining when to turndown worker pool.
* Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and
* `TEARDOWN_NEVER`.
* `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
* the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down
* if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn
* down.
* If the workers are not torn down by the service, they will
* continue to run and use Google Compute Engine VM resources in the
* user's project until they are explicitly terminated by the user.
* Because of this, Google recommends using the `TEARDOWN_ALWAYS`
* policy except for small, manually supervised test jobs.
* If unknown or unspecified, the service will attempt to choose a reasonable
* default.
*
*
* .google.dataflow.v1beta3.TeardownPolicy teardown_policy = 6;
*
* @return This builder for chaining.
*/
public Builder clearTeardownPolicy() {
bitField0_ = (bitField0_ & ~0x00000020);
teardownPolicy_ = 0;
onChanged();
return this;
}
private int diskSizeGb_;
/**
*
*
*
* Size of root disk for VMs, in GB. If zero or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* int32 disk_size_gb = 7;
*
* @return The diskSizeGb.
*/
@java.lang.Override
public int getDiskSizeGb() {
return diskSizeGb_;
}
/**
*
*
*
* Size of root disk for VMs, in GB. If zero or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* int32 disk_size_gb = 7;
*
* @param value The diskSizeGb to set.
* @return This builder for chaining.
*/
public Builder setDiskSizeGb(int value) {
diskSizeGb_ = value;
bitField0_ |= 0x00000040;
onChanged();
return this;
}
/**
*
*
*
* Size of root disk for VMs, in GB. If zero or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* int32 disk_size_gb = 7;
*
* @return This builder for chaining.
*/
public Builder clearDiskSizeGb() {
bitField0_ = (bitField0_ & ~0x00000040);
diskSizeGb_ = 0;
onChanged();
return this;
}
private java.lang.Object diskType_ = "";
/**
*
*
*
* Type of root disk for VMs. If empty or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* string disk_type = 16;
*
* @return The diskType.
*/
public java.lang.String getDiskType() {
java.lang.Object ref = diskType_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
diskType_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* Type of root disk for VMs. If empty or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* string disk_type = 16;
*
* @return The bytes for diskType.
*/
public com.google.protobuf.ByteString getDiskTypeBytes() {
java.lang.Object ref = diskType_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
diskType_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* Type of root disk for VMs. If empty or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* string disk_type = 16;
*
* @param value The diskType to set.
* @return This builder for chaining.
*/
public Builder setDiskType(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
diskType_ = value;
bitField0_ |= 0x00000080;
onChanged();
return this;
}
/**
*
*
*
* Type of root disk for VMs. If empty or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* string disk_type = 16;
*
* @return This builder for chaining.
*/
public Builder clearDiskType() {
diskType_ = getDefaultInstance().getDiskType();
bitField0_ = (bitField0_ & ~0x00000080);
onChanged();
return this;
}
/**
*
*
*
* Type of root disk for VMs. If empty or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* string disk_type = 16;
*
* @param value The bytes for diskType to set.
* @return This builder for chaining.
*/
public Builder setDiskTypeBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
diskType_ = value;
bitField0_ |= 0x00000080;
onChanged();
return this;
}
private java.lang.Object diskSourceImage_ = "";
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @return The diskSourceImage.
*/
public java.lang.String getDiskSourceImage() {
java.lang.Object ref = diskSourceImage_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
diskSourceImage_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @return The bytes for diskSourceImage.
*/
public com.google.protobuf.ByteString getDiskSourceImageBytes() {
java.lang.Object ref = diskSourceImage_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
diskSourceImage_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @param value The diskSourceImage to set.
* @return This builder for chaining.
*/
public Builder setDiskSourceImage(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
diskSourceImage_ = value;
bitField0_ |= 0x00000100;
onChanged();
return this;
}
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @return This builder for chaining.
*/
public Builder clearDiskSourceImage() {
diskSourceImage_ = getDefaultInstance().getDiskSourceImage();
bitField0_ = (bitField0_ & ~0x00000100);
onChanged();
return this;
}
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @param value The bytes for diskSourceImage to set.
* @return This builder for chaining.
*/
public Builder setDiskSourceImageBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
diskSourceImage_ = value;
bitField0_ |= 0x00000100;
onChanged();
return this;
}
private java.lang.Object zone_ = "";
/**
*
*
*
* Zone to run the worker pools in. If empty or unspecified, the service
* will attempt to choose a reasonable default.
*
*
* string zone = 9;
*
* @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;
}
}
/**
*
*
*
* Zone to run the worker pools in. If empty or unspecified, the service
* will attempt to choose a reasonable default.
*
*
* string zone = 9;
*
* @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;
}
}
/**
*
*
*
* Zone to run the worker pools in. If empty or unspecified, the service
* will attempt to choose a reasonable default.
*
*
* string zone = 9;
*
* @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_ |= 0x00000200;
onChanged();
return this;
}
/**
*
*
*
* Zone to run the worker pools in. If empty or unspecified, the service
* will attempt to choose a reasonable default.
*
*
* string zone = 9;
*
* @return This builder for chaining.
*/
public Builder clearZone() {
zone_ = getDefaultInstance().getZone();
bitField0_ = (bitField0_ & ~0x00000200);
onChanged();
return this;
}
/**
*
*
*
* Zone to run the worker pools in. If empty or unspecified, the service
* will attempt to choose a reasonable default.
*
*
* string zone = 9;
*
* @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_ |= 0x00000200;
onChanged();
return this;
}
private com.google.dataflow.v1beta3.TaskRunnerSettings taskrunnerSettings_;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.dataflow.v1beta3.TaskRunnerSettings,
com.google.dataflow.v1beta3.TaskRunnerSettings.Builder,
com.google.dataflow.v1beta3.TaskRunnerSettingsOrBuilder>
taskrunnerSettingsBuilder_;
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*
* @return Whether the taskrunnerSettings field is set.
*/
public boolean hasTaskrunnerSettings() {
return ((bitField0_ & 0x00000400) != 0);
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*
* @return The taskrunnerSettings.
*/
public com.google.dataflow.v1beta3.TaskRunnerSettings getTaskrunnerSettings() {
if (taskrunnerSettingsBuilder_ == null) {
return taskrunnerSettings_ == null
? com.google.dataflow.v1beta3.TaskRunnerSettings.getDefaultInstance()
: taskrunnerSettings_;
} else {
return taskrunnerSettingsBuilder_.getMessage();
}
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
public Builder setTaskrunnerSettings(com.google.dataflow.v1beta3.TaskRunnerSettings value) {
if (taskrunnerSettingsBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
taskrunnerSettings_ = value;
} else {
taskrunnerSettingsBuilder_.setMessage(value);
}
bitField0_ |= 0x00000400;
onChanged();
return this;
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
public Builder setTaskrunnerSettings(
com.google.dataflow.v1beta3.TaskRunnerSettings.Builder builderForValue) {
if (taskrunnerSettingsBuilder_ == null) {
taskrunnerSettings_ = builderForValue.build();
} else {
taskrunnerSettingsBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00000400;
onChanged();
return this;
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
public Builder mergeTaskrunnerSettings(com.google.dataflow.v1beta3.TaskRunnerSettings value) {
if (taskrunnerSettingsBuilder_ == null) {
if (((bitField0_ & 0x00000400) != 0)
&& taskrunnerSettings_ != null
&& taskrunnerSettings_
!= com.google.dataflow.v1beta3.TaskRunnerSettings.getDefaultInstance()) {
getTaskrunnerSettingsBuilder().mergeFrom(value);
} else {
taskrunnerSettings_ = value;
}
} else {
taskrunnerSettingsBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00000400;
onChanged();
return this;
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
public Builder clearTaskrunnerSettings() {
bitField0_ = (bitField0_ & ~0x00000400);
taskrunnerSettings_ = null;
if (taskrunnerSettingsBuilder_ != null) {
taskrunnerSettingsBuilder_.dispose();
taskrunnerSettingsBuilder_ = null;
}
onChanged();
return this;
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
public com.google.dataflow.v1beta3.TaskRunnerSettings.Builder getTaskrunnerSettingsBuilder() {
bitField0_ |= 0x00000400;
onChanged();
return getTaskrunnerSettingsFieldBuilder().getBuilder();
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
public com.google.dataflow.v1beta3.TaskRunnerSettingsOrBuilder
getTaskrunnerSettingsOrBuilder() {
if (taskrunnerSettingsBuilder_ != null) {
return taskrunnerSettingsBuilder_.getMessageOrBuilder();
} else {
return taskrunnerSettings_ == null
? com.google.dataflow.v1beta3.TaskRunnerSettings.getDefaultInstance()
: taskrunnerSettings_;
}
}
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.dataflow.v1beta3.TaskRunnerSettings,
com.google.dataflow.v1beta3.TaskRunnerSettings.Builder,
com.google.dataflow.v1beta3.TaskRunnerSettingsOrBuilder>
getTaskrunnerSettingsFieldBuilder() {
if (taskrunnerSettingsBuilder_ == null) {
taskrunnerSettingsBuilder_ =
new com.google.protobuf.SingleFieldBuilderV3<
com.google.dataflow.v1beta3.TaskRunnerSettings,
com.google.dataflow.v1beta3.TaskRunnerSettings.Builder,
com.google.dataflow.v1beta3.TaskRunnerSettingsOrBuilder>(
getTaskrunnerSettings(), getParentForChildren(), isClean());
taskrunnerSettings_ = null;
}
return taskrunnerSettingsBuilder_;
}
private java.lang.Object onHostMaintenance_ = "";
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @return The onHostMaintenance.
*/
public java.lang.String getOnHostMaintenance() {
java.lang.Object ref = onHostMaintenance_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
onHostMaintenance_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @return The bytes for onHostMaintenance.
*/
public com.google.protobuf.ByteString getOnHostMaintenanceBytes() {
java.lang.Object ref = onHostMaintenance_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
onHostMaintenance_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @param value The onHostMaintenance to set.
* @return This builder for chaining.
*/
public Builder setOnHostMaintenance(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
onHostMaintenance_ = value;
bitField0_ |= 0x00000800;
onChanged();
return this;
}
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @return This builder for chaining.
*/
public Builder clearOnHostMaintenance() {
onHostMaintenance_ = getDefaultInstance().getOnHostMaintenance();
bitField0_ = (bitField0_ & ~0x00000800);
onChanged();
return this;
}
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @param value The bytes for onHostMaintenance to set.
* @return This builder for chaining.
*/
public Builder setOnHostMaintenanceBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
onHostMaintenance_ = value;
bitField0_ |= 0x00000800;
onChanged();
return this;
}
private java.util.List dataDisks_ =
java.util.Collections.emptyList();
private void ensureDataDisksIsMutable() {
if (!((bitField0_ & 0x00001000) != 0)) {
dataDisks_ = new java.util.ArrayList(dataDisks_);
bitField0_ |= 0x00001000;
}
}
private com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.Disk,
com.google.dataflow.v1beta3.Disk.Builder,
com.google.dataflow.v1beta3.DiskOrBuilder>
dataDisksBuilder_;
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public java.util.List getDataDisksList() {
if (dataDisksBuilder_ == null) {
return java.util.Collections.unmodifiableList(dataDisks_);
} else {
return dataDisksBuilder_.getMessageList();
}
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public int getDataDisksCount() {
if (dataDisksBuilder_ == null) {
return dataDisks_.size();
} else {
return dataDisksBuilder_.getCount();
}
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public com.google.dataflow.v1beta3.Disk getDataDisks(int index) {
if (dataDisksBuilder_ == null) {
return dataDisks_.get(index);
} else {
return dataDisksBuilder_.getMessage(index);
}
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder setDataDisks(int index, com.google.dataflow.v1beta3.Disk value) {
if (dataDisksBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureDataDisksIsMutable();
dataDisks_.set(index, value);
onChanged();
} else {
dataDisksBuilder_.setMessage(index, value);
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder setDataDisks(
int index, com.google.dataflow.v1beta3.Disk.Builder builderForValue) {
if (dataDisksBuilder_ == null) {
ensureDataDisksIsMutable();
dataDisks_.set(index, builderForValue.build());
onChanged();
} else {
dataDisksBuilder_.setMessage(index, builderForValue.build());
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder addDataDisks(com.google.dataflow.v1beta3.Disk value) {
if (dataDisksBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureDataDisksIsMutable();
dataDisks_.add(value);
onChanged();
} else {
dataDisksBuilder_.addMessage(value);
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder addDataDisks(int index, com.google.dataflow.v1beta3.Disk value) {
if (dataDisksBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureDataDisksIsMutable();
dataDisks_.add(index, value);
onChanged();
} else {
dataDisksBuilder_.addMessage(index, value);
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder addDataDisks(com.google.dataflow.v1beta3.Disk.Builder builderForValue) {
if (dataDisksBuilder_ == null) {
ensureDataDisksIsMutable();
dataDisks_.add(builderForValue.build());
onChanged();
} else {
dataDisksBuilder_.addMessage(builderForValue.build());
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder addDataDisks(
int index, com.google.dataflow.v1beta3.Disk.Builder builderForValue) {
if (dataDisksBuilder_ == null) {
ensureDataDisksIsMutable();
dataDisks_.add(index, builderForValue.build());
onChanged();
} else {
dataDisksBuilder_.addMessage(index, builderForValue.build());
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder addAllDataDisks(
java.lang.Iterable values) {
if (dataDisksBuilder_ == null) {
ensureDataDisksIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(values, dataDisks_);
onChanged();
} else {
dataDisksBuilder_.addAllMessages(values);
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder clearDataDisks() {
if (dataDisksBuilder_ == null) {
dataDisks_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00001000);
onChanged();
} else {
dataDisksBuilder_.clear();
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public Builder removeDataDisks(int index) {
if (dataDisksBuilder_ == null) {
ensureDataDisksIsMutable();
dataDisks_.remove(index);
onChanged();
} else {
dataDisksBuilder_.remove(index);
}
return this;
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public com.google.dataflow.v1beta3.Disk.Builder getDataDisksBuilder(int index) {
return getDataDisksFieldBuilder().getBuilder(index);
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public com.google.dataflow.v1beta3.DiskOrBuilder getDataDisksOrBuilder(int index) {
if (dataDisksBuilder_ == null) {
return dataDisks_.get(index);
} else {
return dataDisksBuilder_.getMessageOrBuilder(index);
}
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public java.util.List
getDataDisksOrBuilderList() {
if (dataDisksBuilder_ != null) {
return dataDisksBuilder_.getMessageOrBuilderList();
} else {
return java.util.Collections.unmodifiableList(dataDisks_);
}
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public com.google.dataflow.v1beta3.Disk.Builder addDataDisksBuilder() {
return getDataDisksFieldBuilder()
.addBuilder(com.google.dataflow.v1beta3.Disk.getDefaultInstance());
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public com.google.dataflow.v1beta3.Disk.Builder addDataDisksBuilder(int index) {
return getDataDisksFieldBuilder()
.addBuilder(index, com.google.dataflow.v1beta3.Disk.getDefaultInstance());
}
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
public java.util.List getDataDisksBuilderList() {
return getDataDisksFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.Disk,
com.google.dataflow.v1beta3.Disk.Builder,
com.google.dataflow.v1beta3.DiskOrBuilder>
getDataDisksFieldBuilder() {
if (dataDisksBuilder_ == null) {
dataDisksBuilder_ =
new com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.Disk,
com.google.dataflow.v1beta3.Disk.Builder,
com.google.dataflow.v1beta3.DiskOrBuilder>(
dataDisks_, ((bitField0_ & 0x00001000) != 0), getParentForChildren(), isClean());
dataDisks_ = null;
}
return dataDisksBuilder_;
}
private com.google.protobuf.MapField metadata_;
private com.google.protobuf.MapField internalGetMetadata() {
if (metadata_ == null) {
return com.google.protobuf.MapField.emptyMapField(MetadataDefaultEntryHolder.defaultEntry);
}
return metadata_;
}
private com.google.protobuf.MapField
internalGetMutableMetadata() {
if (metadata_ == null) {
metadata_ =
com.google.protobuf.MapField.newMapField(MetadataDefaultEntryHolder.defaultEntry);
}
if (!metadata_.isMutable()) {
metadata_ = metadata_.copy();
}
bitField0_ |= 0x00002000;
onChanged();
return metadata_;
}
public int getMetadataCount() {
return internalGetMetadata().getMap().size();
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
@java.lang.Override
public boolean containsMetadata(java.lang.String key) {
if (key == null) {
throw new NullPointerException("map key");
}
return internalGetMetadata().getMap().containsKey(key);
}
/** Use {@link #getMetadataMap()} instead. */
@java.lang.Override
@java.lang.Deprecated
public java.util.Map getMetadata() {
return getMetadataMap();
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
@java.lang.Override
public java.util.Map getMetadataMap() {
return internalGetMetadata().getMap();
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
@java.lang.Override
public /* nullable */ java.lang.String getMetadataOrDefault(
java.lang.String key,
/* nullable */
java.lang.String defaultValue) {
if (key == null) {
throw new NullPointerException("map key");
}
java.util.Map map = internalGetMetadata().getMap();
return map.containsKey(key) ? map.get(key) : defaultValue;
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
@java.lang.Override
public java.lang.String getMetadataOrThrow(java.lang.String key) {
if (key == null) {
throw new NullPointerException("map key");
}
java.util.Map map = internalGetMetadata().getMap();
if (!map.containsKey(key)) {
throw new java.lang.IllegalArgumentException();
}
return map.get(key);
}
public Builder clearMetadata() {
bitField0_ = (bitField0_ & ~0x00002000);
internalGetMutableMetadata().getMutableMap().clear();
return this;
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
public Builder removeMetadata(java.lang.String key) {
if (key == null) {
throw new NullPointerException("map key");
}
internalGetMutableMetadata().getMutableMap().remove(key);
return this;
}
/** Use alternate mutation accessors instead. */
@java.lang.Deprecated
public java.util.Map getMutableMetadata() {
bitField0_ |= 0x00002000;
return internalGetMutableMetadata().getMutableMap();
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
public Builder putMetadata(java.lang.String key, java.lang.String value) {
if (key == null) {
throw new NullPointerException("map key");
}
if (value == null) {
throw new NullPointerException("map value");
}
internalGetMutableMetadata().getMutableMap().put(key, value);
bitField0_ |= 0x00002000;
return this;
}
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
public Builder putAllMetadata(java.util.Map values) {
internalGetMutableMetadata().getMutableMap().putAll(values);
bitField0_ |= 0x00002000;
return this;
}
private com.google.dataflow.v1beta3.AutoscalingSettings autoscalingSettings_;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.dataflow.v1beta3.AutoscalingSettings,
com.google.dataflow.v1beta3.AutoscalingSettings.Builder,
com.google.dataflow.v1beta3.AutoscalingSettingsOrBuilder>
autoscalingSettingsBuilder_;
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*
* @return Whether the autoscalingSettings field is set.
*/
public boolean hasAutoscalingSettings() {
return ((bitField0_ & 0x00004000) != 0);
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*
* @return The autoscalingSettings.
*/
public com.google.dataflow.v1beta3.AutoscalingSettings getAutoscalingSettings() {
if (autoscalingSettingsBuilder_ == null) {
return autoscalingSettings_ == null
? com.google.dataflow.v1beta3.AutoscalingSettings.getDefaultInstance()
: autoscalingSettings_;
} else {
return autoscalingSettingsBuilder_.getMessage();
}
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
public Builder setAutoscalingSettings(com.google.dataflow.v1beta3.AutoscalingSettings value) {
if (autoscalingSettingsBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
autoscalingSettings_ = value;
} else {
autoscalingSettingsBuilder_.setMessage(value);
}
bitField0_ |= 0x00004000;
onChanged();
return this;
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
public Builder setAutoscalingSettings(
com.google.dataflow.v1beta3.AutoscalingSettings.Builder builderForValue) {
if (autoscalingSettingsBuilder_ == null) {
autoscalingSettings_ = builderForValue.build();
} else {
autoscalingSettingsBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00004000;
onChanged();
return this;
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
public Builder mergeAutoscalingSettings(com.google.dataflow.v1beta3.AutoscalingSettings value) {
if (autoscalingSettingsBuilder_ == null) {
if (((bitField0_ & 0x00004000) != 0)
&& autoscalingSettings_ != null
&& autoscalingSettings_
!= com.google.dataflow.v1beta3.AutoscalingSettings.getDefaultInstance()) {
getAutoscalingSettingsBuilder().mergeFrom(value);
} else {
autoscalingSettings_ = value;
}
} else {
autoscalingSettingsBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00004000;
onChanged();
return this;
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
public Builder clearAutoscalingSettings() {
bitField0_ = (bitField0_ & ~0x00004000);
autoscalingSettings_ = null;
if (autoscalingSettingsBuilder_ != null) {
autoscalingSettingsBuilder_.dispose();
autoscalingSettingsBuilder_ = null;
}
onChanged();
return this;
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
public com.google.dataflow.v1beta3.AutoscalingSettings.Builder getAutoscalingSettingsBuilder() {
bitField0_ |= 0x00004000;
onChanged();
return getAutoscalingSettingsFieldBuilder().getBuilder();
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
public com.google.dataflow.v1beta3.AutoscalingSettingsOrBuilder
getAutoscalingSettingsOrBuilder() {
if (autoscalingSettingsBuilder_ != null) {
return autoscalingSettingsBuilder_.getMessageOrBuilder();
} else {
return autoscalingSettings_ == null
? com.google.dataflow.v1beta3.AutoscalingSettings.getDefaultInstance()
: autoscalingSettings_;
}
}
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.dataflow.v1beta3.AutoscalingSettings,
com.google.dataflow.v1beta3.AutoscalingSettings.Builder,
com.google.dataflow.v1beta3.AutoscalingSettingsOrBuilder>
getAutoscalingSettingsFieldBuilder() {
if (autoscalingSettingsBuilder_ == null) {
autoscalingSettingsBuilder_ =
new com.google.protobuf.SingleFieldBuilderV3<
com.google.dataflow.v1beta3.AutoscalingSettings,
com.google.dataflow.v1beta3.AutoscalingSettings.Builder,
com.google.dataflow.v1beta3.AutoscalingSettingsOrBuilder>(
getAutoscalingSettings(), getParentForChildren(), isClean());
autoscalingSettings_ = null;
}
return autoscalingSettingsBuilder_;
}
private com.google.protobuf.Any poolArgs_;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.protobuf.Any,
com.google.protobuf.Any.Builder,
com.google.protobuf.AnyOrBuilder>
poolArgsBuilder_;
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*
* @return Whether the poolArgs field is set.
*/
public boolean hasPoolArgs() {
return ((bitField0_ & 0x00008000) != 0);
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*
* @return The poolArgs.
*/
public com.google.protobuf.Any getPoolArgs() {
if (poolArgsBuilder_ == null) {
return poolArgs_ == null ? com.google.protobuf.Any.getDefaultInstance() : poolArgs_;
} else {
return poolArgsBuilder_.getMessage();
}
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
public Builder setPoolArgs(com.google.protobuf.Any value) {
if (poolArgsBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
poolArgs_ = value;
} else {
poolArgsBuilder_.setMessage(value);
}
bitField0_ |= 0x00008000;
onChanged();
return this;
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
public Builder setPoolArgs(com.google.protobuf.Any.Builder builderForValue) {
if (poolArgsBuilder_ == null) {
poolArgs_ = builderForValue.build();
} else {
poolArgsBuilder_.setMessage(builderForValue.build());
}
bitField0_ |= 0x00008000;
onChanged();
return this;
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
public Builder mergePoolArgs(com.google.protobuf.Any value) {
if (poolArgsBuilder_ == null) {
if (((bitField0_ & 0x00008000) != 0)
&& poolArgs_ != null
&& poolArgs_ != com.google.protobuf.Any.getDefaultInstance()) {
getPoolArgsBuilder().mergeFrom(value);
} else {
poolArgs_ = value;
}
} else {
poolArgsBuilder_.mergeFrom(value);
}
bitField0_ |= 0x00008000;
onChanged();
return this;
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
public Builder clearPoolArgs() {
bitField0_ = (bitField0_ & ~0x00008000);
poolArgs_ = null;
if (poolArgsBuilder_ != null) {
poolArgsBuilder_.dispose();
poolArgsBuilder_ = null;
}
onChanged();
return this;
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
public com.google.protobuf.Any.Builder getPoolArgsBuilder() {
bitField0_ |= 0x00008000;
onChanged();
return getPoolArgsFieldBuilder().getBuilder();
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
public com.google.protobuf.AnyOrBuilder getPoolArgsOrBuilder() {
if (poolArgsBuilder_ != null) {
return poolArgsBuilder_.getMessageOrBuilder();
} else {
return poolArgs_ == null ? com.google.protobuf.Any.getDefaultInstance() : poolArgs_;
}
}
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.protobuf.Any,
com.google.protobuf.Any.Builder,
com.google.protobuf.AnyOrBuilder>
getPoolArgsFieldBuilder() {
if (poolArgsBuilder_ == null) {
poolArgsBuilder_ =
new com.google.protobuf.SingleFieldBuilderV3<
com.google.protobuf.Any,
com.google.protobuf.Any.Builder,
com.google.protobuf.AnyOrBuilder>(getPoolArgs(), getParentForChildren(), isClean());
poolArgs_ = null;
}
return poolArgsBuilder_;
}
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 = 17;
*
* @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 = 17;
*
* @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 = 17;
*
* @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_ |= 0x00010000;
onChanged();
return this;
}
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 17;
*
* @return This builder for chaining.
*/
public Builder clearNetwork() {
network_ = getDefaultInstance().getNetwork();
bitField0_ = (bitField0_ & ~0x00010000);
onChanged();
return this;
}
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 17;
*
* @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_ |= 0x00010000;
onChanged();
return this;
}
private java.lang.Object subnetwork_ = "";
/**
*
*
*
* Subnetwork to which VMs will be assigned, if desired. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @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. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @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. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @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_ |= 0x00020000;
onChanged();
return this;
}
/**
*
*
*
* Subnetwork to which VMs will be assigned, if desired. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @return This builder for chaining.
*/
public Builder clearSubnetwork() {
subnetwork_ = getDefaultInstance().getSubnetwork();
bitField0_ = (bitField0_ & ~0x00020000);
onChanged();
return this;
}
/**
*
*
*
* Subnetwork to which VMs will be assigned, if desired. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @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_ |= 0x00020000;
onChanged();
return this;
}
private java.lang.Object workerHarnessContainerImage_ = "";
/**
*
*
*
* Required. Docker container image that executes the Cloud Dataflow worker
* harness, residing in Google Container Registry.
* Deprecated for the Fn API path. Use sdk_harness_container_images instead.
*
*
* string worker_harness_container_image = 18;
*
* @return The workerHarnessContainerImage.
*/
public java.lang.String getWorkerHarnessContainerImage() {
java.lang.Object ref = workerHarnessContainerImage_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
workerHarnessContainerImage_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
*
*
*
* Required. Docker container image that executes the Cloud Dataflow worker
* harness, residing in Google Container Registry.
* Deprecated for the Fn API path. Use sdk_harness_container_images instead.
*
*
* string worker_harness_container_image = 18;
*
* @return The bytes for workerHarnessContainerImage.
*/
public com.google.protobuf.ByteString getWorkerHarnessContainerImageBytes() {
java.lang.Object ref = workerHarnessContainerImage_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
workerHarnessContainerImage_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
*
*
*
* Required. Docker container image that executes the Cloud Dataflow worker
* harness, residing in Google Container Registry.
* Deprecated for the Fn API path. Use sdk_harness_container_images instead.
*
*
* string worker_harness_container_image = 18;
*
* @param value The workerHarnessContainerImage to set.
* @return This builder for chaining.
*/
public Builder setWorkerHarnessContainerImage(java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
workerHarnessContainerImage_ = value;
bitField0_ |= 0x00040000;
onChanged();
return this;
}
/**
*
*
*
* Required. Docker container image that executes the Cloud Dataflow worker
* harness, residing in Google Container Registry.
* Deprecated for the Fn API path. Use sdk_harness_container_images instead.
*
*
* string worker_harness_container_image = 18;
*
* @return This builder for chaining.
*/
public Builder clearWorkerHarnessContainerImage() {
workerHarnessContainerImage_ = getDefaultInstance().getWorkerHarnessContainerImage();
bitField0_ = (bitField0_ & ~0x00040000);
onChanged();
return this;
}
/**
*
*
*
* Required. Docker container image that executes the Cloud Dataflow worker
* harness, residing in Google Container Registry.
* Deprecated for the Fn API path. Use sdk_harness_container_images instead.
*
*
* string worker_harness_container_image = 18;
*
* @param value The bytes for workerHarnessContainerImage to set.
* @return This builder for chaining.
*/
public Builder setWorkerHarnessContainerImageBytes(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
workerHarnessContainerImage_ = value;
bitField0_ |= 0x00040000;
onChanged();
return this;
}
private int numThreadsPerWorker_;
/**
*
*
*
* The number of threads per worker harness. If empty or unspecified, the
* service will choose a number of threads (according to the number of cores
* on the selected machine type for batch, or 1 by convention for streaming).
*
*
* int32 num_threads_per_worker = 20;
*
* @return The numThreadsPerWorker.
*/
@java.lang.Override
public int getNumThreadsPerWorker() {
return numThreadsPerWorker_;
}
/**
*
*
*
* The number of threads per worker harness. If empty or unspecified, the
* service will choose a number of threads (according to the number of cores
* on the selected machine type for batch, or 1 by convention for streaming).
*
*
* int32 num_threads_per_worker = 20;
*
* @param value The numThreadsPerWorker to set.
* @return This builder for chaining.
*/
public Builder setNumThreadsPerWorker(int value) {
numThreadsPerWorker_ = value;
bitField0_ |= 0x00080000;
onChanged();
return this;
}
/**
*
*
*
* The number of threads per worker harness. If empty or unspecified, the
* service will choose a number of threads (according to the number of cores
* on the selected machine type for batch, or 1 by convention for streaming).
*
*
* int32 num_threads_per_worker = 20;
*
* @return This builder for chaining.
*/
public Builder clearNumThreadsPerWorker() {
bitField0_ = (bitField0_ & ~0x00080000);
numThreadsPerWorker_ = 0;
onChanged();
return this;
}
private int ipConfiguration_ = 0;
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
*
* @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 = 21;
*
* @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_ |= 0x00100000;
onChanged();
return this;
}
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
*
* @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 = 21;
*
* @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_ |= 0x00100000;
ipConfiguration_ = value.getNumber();
onChanged();
return this;
}
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
*
* @return This builder for chaining.
*/
public Builder clearIpConfiguration() {
bitField0_ = (bitField0_ & ~0x00100000);
ipConfiguration_ = 0;
onChanged();
return this;
}
private java.util.List
sdkHarnessContainerImages_ = java.util.Collections.emptyList();
private void ensureSdkHarnessContainerImagesIsMutable() {
if (!((bitField0_ & 0x00200000) != 0)) {
sdkHarnessContainerImages_ =
new java.util.ArrayList(
sdkHarnessContainerImages_);
bitField0_ |= 0x00200000;
}
}
private com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.SdkHarnessContainerImage,
com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder,
com.google.dataflow.v1beta3.SdkHarnessContainerImageOrBuilder>
sdkHarnessContainerImagesBuilder_;
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public java.util.List
getSdkHarnessContainerImagesList() {
if (sdkHarnessContainerImagesBuilder_ == null) {
return java.util.Collections.unmodifiableList(sdkHarnessContainerImages_);
} else {
return sdkHarnessContainerImagesBuilder_.getMessageList();
}
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public int getSdkHarnessContainerImagesCount() {
if (sdkHarnessContainerImagesBuilder_ == null) {
return sdkHarnessContainerImages_.size();
} else {
return sdkHarnessContainerImagesBuilder_.getCount();
}
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public com.google.dataflow.v1beta3.SdkHarnessContainerImage getSdkHarnessContainerImages(
int index) {
if (sdkHarnessContainerImagesBuilder_ == null) {
return sdkHarnessContainerImages_.get(index);
} else {
return sdkHarnessContainerImagesBuilder_.getMessage(index);
}
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder setSdkHarnessContainerImages(
int index, com.google.dataflow.v1beta3.SdkHarnessContainerImage value) {
if (sdkHarnessContainerImagesBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.set(index, value);
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.setMessage(index, value);
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder setSdkHarnessContainerImages(
int index, com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder builderForValue) {
if (sdkHarnessContainerImagesBuilder_ == null) {
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.set(index, builderForValue.build());
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.setMessage(index, builderForValue.build());
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder addSdkHarnessContainerImages(
com.google.dataflow.v1beta3.SdkHarnessContainerImage value) {
if (sdkHarnessContainerImagesBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.add(value);
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.addMessage(value);
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder addSdkHarnessContainerImages(
int index, com.google.dataflow.v1beta3.SdkHarnessContainerImage value) {
if (sdkHarnessContainerImagesBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.add(index, value);
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.addMessage(index, value);
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder addSdkHarnessContainerImages(
com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder builderForValue) {
if (sdkHarnessContainerImagesBuilder_ == null) {
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.add(builderForValue.build());
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.addMessage(builderForValue.build());
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder addSdkHarnessContainerImages(
int index, com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder builderForValue) {
if (sdkHarnessContainerImagesBuilder_ == null) {
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.add(index, builderForValue.build());
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.addMessage(index, builderForValue.build());
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder addAllSdkHarnessContainerImages(
java.lang.Iterable values) {
if (sdkHarnessContainerImagesBuilder_ == null) {
ensureSdkHarnessContainerImagesIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(values, sdkHarnessContainerImages_);
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.addAllMessages(values);
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder clearSdkHarnessContainerImages() {
if (sdkHarnessContainerImagesBuilder_ == null) {
sdkHarnessContainerImages_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00200000);
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.clear();
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public Builder removeSdkHarnessContainerImages(int index) {
if (sdkHarnessContainerImagesBuilder_ == null) {
ensureSdkHarnessContainerImagesIsMutable();
sdkHarnessContainerImages_.remove(index);
onChanged();
} else {
sdkHarnessContainerImagesBuilder_.remove(index);
}
return this;
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder
getSdkHarnessContainerImagesBuilder(int index) {
return getSdkHarnessContainerImagesFieldBuilder().getBuilder(index);
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public com.google.dataflow.v1beta3.SdkHarnessContainerImageOrBuilder
getSdkHarnessContainerImagesOrBuilder(int index) {
if (sdkHarnessContainerImagesBuilder_ == null) {
return sdkHarnessContainerImages_.get(index);
} else {
return sdkHarnessContainerImagesBuilder_.getMessageOrBuilder(index);
}
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public java.util.List
getSdkHarnessContainerImagesOrBuilderList() {
if (sdkHarnessContainerImagesBuilder_ != null) {
return sdkHarnessContainerImagesBuilder_.getMessageOrBuilderList();
} else {
return java.util.Collections.unmodifiableList(sdkHarnessContainerImages_);
}
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder
addSdkHarnessContainerImagesBuilder() {
return getSdkHarnessContainerImagesFieldBuilder()
.addBuilder(com.google.dataflow.v1beta3.SdkHarnessContainerImage.getDefaultInstance());
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder
addSdkHarnessContainerImagesBuilder(int index) {
return getSdkHarnessContainerImagesFieldBuilder()
.addBuilder(
index, com.google.dataflow.v1beta3.SdkHarnessContainerImage.getDefaultInstance());
}
/**
*
*
*
* Set of SDK harness containers needed to execute this pipeline. This will
* only be set in the Fn API path. For non-cross-language pipelines this
* should have only one entry. Cross-language pipelines will have two or more
* entries.
*
*
*
* repeated .google.dataflow.v1beta3.SdkHarnessContainerImage sdk_harness_container_images = 22;
*
*/
public java.util.List
getSdkHarnessContainerImagesBuilderList() {
return getSdkHarnessContainerImagesFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.SdkHarnessContainerImage,
com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder,
com.google.dataflow.v1beta3.SdkHarnessContainerImageOrBuilder>
getSdkHarnessContainerImagesFieldBuilder() {
if (sdkHarnessContainerImagesBuilder_ == null) {
sdkHarnessContainerImagesBuilder_ =
new com.google.protobuf.RepeatedFieldBuilderV3<
com.google.dataflow.v1beta3.SdkHarnessContainerImage,
com.google.dataflow.v1beta3.SdkHarnessContainerImage.Builder,
com.google.dataflow.v1beta3.SdkHarnessContainerImageOrBuilder>(
sdkHarnessContainerImages_,
((bitField0_ & 0x00200000) != 0),
getParentForChildren(),
isClean());
sdkHarnessContainerImages_ = null;
}
return sdkHarnessContainerImagesBuilder_;
}
@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.WorkerPool)
}
// @@protoc_insertion_point(class_scope:google.dataflow.v1beta3.WorkerPool)
private static final com.google.dataflow.v1beta3.WorkerPool DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new com.google.dataflow.v1beta3.WorkerPool();
}
public static com.google.dataflow.v1beta3.WorkerPool getDefaultInstance() {
return DEFAULT_INSTANCE;
}
private static final com.google.protobuf.Parser PARSER =
new com.google.protobuf.AbstractParser() {
@java.lang.Override
public WorkerPool 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.WorkerPool getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}