Package com.google.dataflow.v1beta3

Class WorkerPool.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>
com.google.dataflow.v1beta3.WorkerPool.Builder
All Implemented Interfaces:
WorkerPoolOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
WorkerPool
public static final class WorkerPool.Builder extends com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder> implements WorkerPoolOrBuilder
 Describes one particular pool of Cloud Dataflow workers to be
 instantiated by the Cloud Dataflow service in order to perform the
 computations required by a job.  Note that a workflow job may use
 multiple pools, in order to match the various computational
 requirements of the various stages of the job.
Protobuf type google.dataflow.v1beta3.WorkerPool

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
      Overrides:
      internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>

    • internalGetMutableMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
      Overrides:
      internalGetMutableMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>

    • clear

      public WorkerPool.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>

    • getDefaultInstanceForType

      public WorkerPool getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public WorkerPool build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public WorkerPool buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public WorkerPool.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<WorkerPool.Builder>

    • mergeFrom

      public WorkerPool.Builder mergeFrom(WorkerPool other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<WorkerPool.Builder>

    • mergeFrom

      public WorkerPool.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<WorkerPool.Builder>
      Throws:
      IOException

    • getKind

      public String getKind()
       The kind of the worker pool; currently only `harness` and `shuffle`
 are supported.
      string kind = 1;
      Specified by:
      getKind in interface WorkerPoolOrBuilder
      Returns:
      The kind.

    • getKindBytes

      public com.google.protobuf.ByteString getKindBytes()
       The kind of the worker pool; currently only `harness` and `shuffle`
 are supported.
      string kind = 1;
      Specified by:
      getKindBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for kind.

    • setKind

      public WorkerPool.Builder setKind(String value)
       The kind of the worker pool; currently only `harness` and `shuffle`
 are supported.
      string kind = 1;
      Parameters:
      value - The kind to set.
      Returns:
      This builder for chaining.

    • clearKind

      public WorkerPool.Builder clearKind()
       The kind of the worker pool; currently only `harness` and `shuffle`
 are supported.
      string kind = 1;
      Returns:
      This builder for chaining.

    • setKindBytes

      public WorkerPool.Builder setKindBytes(com.google.protobuf.ByteString value)
       The kind of the worker pool; currently only `harness` and `shuffle`
 are supported.
      string kind = 1;
      Parameters:
      value - The bytes for kind to set.
      Returns:
      This builder for chaining.

    • getNumWorkers

      public int getNumWorkers()
       Number of Google Compute Engine workers in this pool needed to
 execute the job.  If zero or unspecified, the service will
 attempt to choose a reasonable default.
      int32 num_workers = 2;
      Specified by:
      getNumWorkers in interface WorkerPoolOrBuilder
      Returns:
      The numWorkers.

    • setNumWorkers

      public WorkerPool.Builder setNumWorkers(int value)
       Number of Google Compute Engine workers in this pool needed to
 execute the job.  If zero or unspecified, the service will
 attempt to choose a reasonable default.
      int32 num_workers = 2;
      Parameters:
      value - The numWorkers to set.
      Returns:
      This builder for chaining.

    • clearNumWorkers

      public WorkerPool.Builder clearNumWorkers()
       Number of Google Compute Engine workers in this pool needed to
 execute the job.  If zero or unspecified, the service will
 attempt to choose a reasonable default.
      int32 num_workers = 2;
      Returns:
      This builder for chaining.

    • getPackagesList

      public List<Package> getPackagesList()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;
      Specified by:
      getPackagesList in interface WorkerPoolOrBuilder

    • getPackagesCount

      public int getPackagesCount()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;
      Specified by:
      getPackagesCount in interface WorkerPoolOrBuilder

    • getPackages

      public Package getPackages(int index)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;
      Specified by:
      getPackages in interface WorkerPoolOrBuilder

    • setPackages

      public WorkerPool.Builder setPackages(int index, Package value)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • setPackages

      public WorkerPool.Builder setPackages(int index, Package.Builder builderForValue)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • addPackages

      public WorkerPool.Builder addPackages(Package value)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • addPackages

      public WorkerPool.Builder addPackages(int index, Package value)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • addPackages

      public WorkerPool.Builder addPackages(Package.Builder builderForValue)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • addPackages

      public WorkerPool.Builder addPackages(int index, Package.Builder builderForValue)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • addAllPackages

      public WorkerPool.Builder addAllPackages(Iterable<? extends Package> values)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • clearPackages

      public WorkerPool.Builder clearPackages()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • removePackages

      public WorkerPool.Builder removePackages(int index)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • getPackagesBuilder

      public Package.Builder getPackagesBuilder(int index)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • getPackagesOrBuilder

      public PackageOrBuilder getPackagesOrBuilder(int index)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;
      Specified by:
      getPackagesOrBuilder in interface WorkerPoolOrBuilder

    • getPackagesOrBuilderList

      public List<? extends PackageOrBuilder> getPackagesOrBuilderList()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;
      Specified by:
      getPackagesOrBuilderList in interface WorkerPoolOrBuilder

    • addPackagesBuilder

      public Package.Builder addPackagesBuilder()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • addPackagesBuilder

      public Package.Builder addPackagesBuilder(int index)
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • getPackagesBuilderList

      public List<Package.Builder> getPackagesBuilderList()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;

    • getDefaultPackageSetValue

      public int getDefaultPackageSetValue()
       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;
      Specified by:
      getDefaultPackageSetValue in interface WorkerPoolOrBuilder
      Returns:
      The enum numeric value on the wire for defaultPackageSet.

    • setDefaultPackageSetValue

      public WorkerPool.Builder setDefaultPackageSetValue(int value)
       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;
      Parameters:
      value - The enum numeric value on the wire for defaultPackageSet to set.
      Returns:
      This builder for chaining.

    • getDefaultPackageSet

      public DefaultPackageSet getDefaultPackageSet()
       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;
      Specified by:
      getDefaultPackageSet in interface WorkerPoolOrBuilder
      Returns:
      The defaultPackageSet.

    • setDefaultPackageSet

      public WorkerPool.Builder setDefaultPackageSet(DefaultPackageSet value)
       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;
      Parameters:
      value - The defaultPackageSet to set.
      Returns:
      This builder for chaining.

    • clearDefaultPackageSet

      public WorkerPool.Builder clearDefaultPackageSet()
       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;
      Returns:
      This builder for chaining.

    • getMachineType

      public String getMachineType()
       Machine type (e.g. "n1-standard-1").  If empty or unspecified, the
 service will attempt to choose a reasonable default.
      string machine_type = 5;
      Specified by:
      getMachineType in interface WorkerPoolOrBuilder
      Returns:
      The machineType.

    • getMachineTypeBytes

      public com.google.protobuf.ByteString getMachineTypeBytes()
       Machine type (e.g. "n1-standard-1").  If empty or unspecified, the
 service will attempt to choose a reasonable default.
      string machine_type = 5;
      Specified by:
      getMachineTypeBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for machineType.

    • setMachineType

      public WorkerPool.Builder setMachineType(String value)
       Machine type (e.g. "n1-standard-1").  If empty or unspecified, the
 service will attempt to choose a reasonable default.
      string machine_type = 5;
      Parameters:
      value - The machineType to set.
      Returns:
      This builder for chaining.

    • clearMachineType

      public WorkerPool.Builder clearMachineType()
       Machine type (e.g. "n1-standard-1").  If empty or unspecified, the
 service will attempt to choose a reasonable default.
      string machine_type = 5;
      Returns:
      This builder for chaining.

    • setMachineTypeBytes

      public WorkerPool.Builder setMachineTypeBytes(com.google.protobuf.ByteString value)
       Machine type (e.g. "n1-standard-1").  If empty or unspecified, the
 service will attempt to choose a reasonable default.
      string machine_type = 5;
      Parameters:
      value - The bytes for machineType to set.
      Returns:
      This builder for chaining.

    • getTeardownPolicyValue

      public int getTeardownPolicyValue()
       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;
      Specified by:
      getTeardownPolicyValue in interface WorkerPoolOrBuilder
      Returns:
      The enum numeric value on the wire for teardownPolicy.

    • setTeardownPolicyValue

      public WorkerPool.Builder setTeardownPolicyValue(int value)
       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;
      Parameters:
      value - The enum numeric value on the wire for teardownPolicy to set.
      Returns:
      This builder for chaining.

    • getTeardownPolicy

      public TeardownPolicy getTeardownPolicy()
       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;
      Specified by:
      getTeardownPolicy in interface WorkerPoolOrBuilder
      Returns:
      The teardownPolicy.

    • setTeardownPolicy

      public WorkerPool.Builder setTeardownPolicy(TeardownPolicy value)
       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;
      Parameters:
      value - The teardownPolicy to set.
      Returns:
      This builder for chaining.

    • clearTeardownPolicy

      public WorkerPool.Builder clearTeardownPolicy()
       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;
      Returns:
      This builder for chaining.

    • getDiskSizeGb

      public int getDiskSizeGb()
       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;
      Specified by:
      getDiskSizeGb in interface WorkerPoolOrBuilder
      Returns:
      The diskSizeGb.

    • setDiskSizeGb

      public WorkerPool.Builder setDiskSizeGb(int value)
       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;
      Parameters:
      value - The diskSizeGb to set.
      Returns:
      This builder for chaining.

    • clearDiskSizeGb

      public WorkerPool.Builder clearDiskSizeGb()
       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;
      Returns:
      This builder for chaining.

    • getDiskType

      public String getDiskType()
       Type of root disk for VMs.  If empty or unspecified, the service will
 attempt to choose a reasonable default.
      string disk_type = 16;
      Specified by:
      getDiskType in interface WorkerPoolOrBuilder
      Returns:
      The diskType.

    • getDiskTypeBytes

      public com.google.protobuf.ByteString getDiskTypeBytes()
       Type of root disk for VMs.  If empty or unspecified, the service will
 attempt to choose a reasonable default.
      string disk_type = 16;
      Specified by:
      getDiskTypeBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for diskType.

    • setDiskType

      public WorkerPool.Builder setDiskType(String value)
       Type of root disk for VMs.  If empty or unspecified, the service will
 attempt to choose a reasonable default.
      string disk_type = 16;
      Parameters:
      value - The diskType to set.
      Returns:
      This builder for chaining.

    • clearDiskType

      public WorkerPool.Builder clearDiskType()
       Type of root disk for VMs.  If empty or unspecified, the service will
 attempt to choose a reasonable default.
      string disk_type = 16;
      Returns:
      This builder for chaining.

    • setDiskTypeBytes

      public WorkerPool.Builder setDiskTypeBytes(com.google.protobuf.ByteString value)
       Type of root disk for VMs.  If empty or unspecified, the service will
 attempt to choose a reasonable default.
      string disk_type = 16;
      Parameters:
      value - The bytes for diskType to set.
      Returns:
      This builder for chaining.

    • getDiskProvisionedIops

      public long getDiskProvisionedIops()
       Optional. IOPS provisioned for the root disk for VMs.
      int64 disk_provisioned_iops = 23 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDiskProvisionedIops in interface WorkerPoolOrBuilder
      Returns:
      The diskProvisionedIops.

    • setDiskProvisionedIops

      public WorkerPool.Builder setDiskProvisionedIops(long value)
       Optional. IOPS provisioned for the root disk for VMs.
      int64 disk_provisioned_iops = 23 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The diskProvisionedIops to set.
      Returns:
      This builder for chaining.

    • clearDiskProvisionedIops

      public WorkerPool.Builder clearDiskProvisionedIops()
       Optional. IOPS provisioned for the root disk for VMs.
      int64 disk_provisioned_iops = 23 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • getDiskProvisionedThroughputMibps

      public long getDiskProvisionedThroughputMibps()
       Optional. Throughput provisioned for the root disk for VMs.
      int64 disk_provisioned_throughput_mibps = 24 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDiskProvisionedThroughputMibps in interface WorkerPoolOrBuilder
      Returns:
      The diskProvisionedThroughputMibps.

    • setDiskProvisionedThroughputMibps

      public WorkerPool.Builder setDiskProvisionedThroughputMibps(long value)
       Optional. Throughput provisioned for the root disk for VMs.
      int64 disk_provisioned_throughput_mibps = 24 [(.google.api.field_behavior) = OPTIONAL];
      Parameters:
      value - The diskProvisionedThroughputMibps to set.
      Returns:
      This builder for chaining.

    • clearDiskProvisionedThroughputMibps

      public WorkerPool.Builder clearDiskProvisionedThroughputMibps()
       Optional. Throughput provisioned for the root disk for VMs.
      int64 disk_provisioned_throughput_mibps = 24 [(.google.api.field_behavior) = OPTIONAL];
      Returns:
      This builder for chaining.

    • getDiskSourceImage

      public String getDiskSourceImage()
       Fully qualified source image for disks.
      string disk_source_image = 8;
      Specified by:
      getDiskSourceImage in interface WorkerPoolOrBuilder
      Returns:
      The diskSourceImage.

    • getDiskSourceImageBytes

      public com.google.protobuf.ByteString getDiskSourceImageBytes()
       Fully qualified source image for disks.
      string disk_source_image = 8;
      Specified by:
      getDiskSourceImageBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for diskSourceImage.

    • setDiskSourceImage

      public WorkerPool.Builder setDiskSourceImage(String value)
       Fully qualified source image for disks.
      string disk_source_image = 8;
      Parameters:
      value - The diskSourceImage to set.
      Returns:
      This builder for chaining.

    • clearDiskSourceImage

      public WorkerPool.Builder clearDiskSourceImage()
       Fully qualified source image for disks.
      string disk_source_image = 8;
      Returns:
      This builder for chaining.

    • setDiskSourceImageBytes

      public WorkerPool.Builder setDiskSourceImageBytes(com.google.protobuf.ByteString value)
       Fully qualified source image for disks.
      string disk_source_image = 8;
      Parameters:
      value - The bytes for diskSourceImage to set.
      Returns:
      This builder for chaining.

    • getZone

      public String getZone()
       Zone to run the worker pools in.  If empty or unspecified, the service
 will attempt to choose a reasonable default.
      string zone = 9;
      Specified by:
      getZone in interface WorkerPoolOrBuilder
      Returns:
      The zone.

    • getZoneBytes

      public com.google.protobuf.ByteString getZoneBytes()
       Zone to run the worker pools in.  If empty or unspecified, the service
 will attempt to choose a reasonable default.
      string zone = 9;
      Specified by:
      getZoneBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for zone.

    • setZone

      public WorkerPool.Builder setZone(String value)
       Zone to run the worker pools in.  If empty or unspecified, the service
 will attempt to choose a reasonable default.
      string zone = 9;
      Parameters:
      value - The zone to set.
      Returns:
      This builder for chaining.

    • clearZone

      public WorkerPool.Builder clearZone()
       Zone to run the worker pools in.  If empty or unspecified, the service
 will attempt to choose a reasonable default.
      string zone = 9;
      Returns:
      This builder for chaining.

    • setZoneBytes

      public WorkerPool.Builder setZoneBytes(com.google.protobuf.ByteString value)
       Zone to run the worker pools in.  If empty or unspecified, the service
 will attempt to choose a reasonable default.
      string zone = 9;
      Parameters:
      value - The bytes for zone to set.
      Returns:
      This builder for chaining.

    • hasTaskrunnerSettings

      public boolean hasTaskrunnerSettings()
       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;
      Specified by:
      hasTaskrunnerSettings in interface WorkerPoolOrBuilder
      Returns:
      Whether the taskrunnerSettings field is set.

    • getTaskrunnerSettings

      public TaskRunnerSettings getTaskrunnerSettings()
       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;
      Specified by:
      getTaskrunnerSettings in interface WorkerPoolOrBuilder
      Returns:
      The taskrunnerSettings.

    • setTaskrunnerSettings

      public WorkerPool.Builder setTaskrunnerSettings(TaskRunnerSettings value)
       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;

    • setTaskrunnerSettings

      public WorkerPool.Builder setTaskrunnerSettings(TaskRunnerSettings.Builder builderForValue)
       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;

    • mergeTaskrunnerSettings

      public WorkerPool.Builder mergeTaskrunnerSettings(TaskRunnerSettings value)
       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;

    • clearTaskrunnerSettings

      public WorkerPool.Builder clearTaskrunnerSettings()
       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;

    • getTaskrunnerSettingsBuilder

      public TaskRunnerSettings.Builder getTaskrunnerSettingsBuilder()
       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;

    • getTaskrunnerSettingsOrBuilder

      public TaskRunnerSettingsOrBuilder getTaskrunnerSettingsOrBuilder()
       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;
      Specified by:
      getTaskrunnerSettingsOrBuilder in interface WorkerPoolOrBuilder

    • getOnHostMaintenance

      public String getOnHostMaintenance()
       The action to take on host maintenance, as defined by the Google
 Compute Engine API.
      string on_host_maintenance = 11;
      Specified by:
      getOnHostMaintenance in interface WorkerPoolOrBuilder
      Returns:
      The onHostMaintenance.

    • getOnHostMaintenanceBytes

      public com.google.protobuf.ByteString getOnHostMaintenanceBytes()
       The action to take on host maintenance, as defined by the Google
 Compute Engine API.
      string on_host_maintenance = 11;
      Specified by:
      getOnHostMaintenanceBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for onHostMaintenance.

    • setOnHostMaintenance

      public WorkerPool.Builder setOnHostMaintenance(String value)
       The action to take on host maintenance, as defined by the Google
 Compute Engine API.
      string on_host_maintenance = 11;
      Parameters:
      value - The onHostMaintenance to set.
      Returns:
      This builder for chaining.

    • clearOnHostMaintenance

      public WorkerPool.Builder clearOnHostMaintenance()
       The action to take on host maintenance, as defined by the Google
 Compute Engine API.
      string on_host_maintenance = 11;
      Returns:
      This builder for chaining.

    • setOnHostMaintenanceBytes

      public WorkerPool.Builder setOnHostMaintenanceBytes(com.google.protobuf.ByteString value)
       The action to take on host maintenance, as defined by the Google
 Compute Engine API.
      string on_host_maintenance = 11;
      Parameters:
      value - The bytes for onHostMaintenance to set.
      Returns:
      This builder for chaining.

    • getDataDisksList

      public List<Disk> getDataDisksList()
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;
      Specified by:
      getDataDisksList in interface WorkerPoolOrBuilder

    • getDataDisksCount

      public int getDataDisksCount()
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;
      Specified by:
      getDataDisksCount in interface WorkerPoolOrBuilder

    • getDataDisks

      public Disk getDataDisks(int index)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;
      Specified by:
      getDataDisks in interface WorkerPoolOrBuilder

    • setDataDisks

      public WorkerPool.Builder setDataDisks(int index, Disk value)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • setDataDisks

      public WorkerPool.Builder setDataDisks(int index, Disk.Builder builderForValue)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • addDataDisks

      public WorkerPool.Builder addDataDisks(Disk value)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • addDataDisks

      public WorkerPool.Builder addDataDisks(int index, Disk value)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • addDataDisks

      public WorkerPool.Builder addDataDisks(Disk.Builder builderForValue)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • addDataDisks

      public WorkerPool.Builder addDataDisks(int index, Disk.Builder builderForValue)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • addAllDataDisks

      public WorkerPool.Builder addAllDataDisks(Iterable<? extends Disk> values)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • clearDataDisks

      public WorkerPool.Builder clearDataDisks()
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • removeDataDisks

      public WorkerPool.Builder removeDataDisks(int index)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • getDataDisksBuilder

      public Disk.Builder getDataDisksBuilder(int index)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • getDataDisksOrBuilder

      public DiskOrBuilder getDataDisksOrBuilder(int index)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;
      Specified by:
      getDataDisksOrBuilder in interface WorkerPoolOrBuilder

    • getDataDisksOrBuilderList

      public List<? extends DiskOrBuilder> getDataDisksOrBuilderList()
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;
      Specified by:
      getDataDisksOrBuilderList in interface WorkerPoolOrBuilder

    • addDataDisksBuilder

      public Disk.Builder addDataDisksBuilder()
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • addDataDisksBuilder

      public Disk.Builder addDataDisksBuilder(int index)
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • getDataDisksBuilderList

      public List<Disk.Builder> getDataDisksBuilderList()
       Data disks that are used by a VM in this workflow.
      repeated .google.dataflow.v1beta3.Disk data_disks = 12;

    • getMetadataCount

      public int getMetadataCount()
      Description copied from interface: WorkerPoolOrBuilder
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;
      Specified by:
      getMetadataCount in interface WorkerPoolOrBuilder

    • containsMetadata

      public boolean containsMetadata(String key)
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;
      Specified by:
      containsMetadata in interface WorkerPoolOrBuilder

    • getMetadata

      @Deprecated public Map<String,String> getMetadata()
      Deprecated.
      Use getMetadataMap() instead.
      Specified by:
      getMetadata in interface WorkerPoolOrBuilder

    • getMetadataMap

      public Map<String,String> getMetadataMap()
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;
      Specified by:
      getMetadataMap in interface WorkerPoolOrBuilder

    • getMetadataOrDefault

      public String getMetadataOrDefault(String key, String defaultValue)
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;
      Specified by:
      getMetadataOrDefault in interface WorkerPoolOrBuilder

    • getMetadataOrThrow

      public String getMetadataOrThrow(String key)
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;
      Specified by:
      getMetadataOrThrow in interface WorkerPoolOrBuilder

    • clearMetadata

      public WorkerPool.Builder clearMetadata()

    • removeMetadata

      public WorkerPool.Builder removeMetadata(String key)
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;

    • getMutableMetadata

      @Deprecated public Map<String,String> getMutableMetadata()
      Deprecated.
      Use alternate mutation accessors instead.

    • putMetadata

      public WorkerPool.Builder putMetadata(String key, String value)
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;

    • putAllMetadata

      public WorkerPool.Builder putAllMetadata(Map<String,String> values)
       Metadata to set on the Google Compute Engine VMs.
      map<string, string> metadata = 13;

    • hasAutoscalingSettings

      public boolean hasAutoscalingSettings()
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
      Specified by:
      hasAutoscalingSettings in interface WorkerPoolOrBuilder
      Returns:
      Whether the autoscalingSettings field is set.

    • getAutoscalingSettings

      public AutoscalingSettings getAutoscalingSettings()
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
      Specified by:
      getAutoscalingSettings in interface WorkerPoolOrBuilder
      Returns:
      The autoscalingSettings.

    • setAutoscalingSettings

      public WorkerPool.Builder setAutoscalingSettings(AutoscalingSettings value)
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;

    • setAutoscalingSettings

      public WorkerPool.Builder setAutoscalingSettings(AutoscalingSettings.Builder builderForValue)
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;

    • mergeAutoscalingSettings

      public WorkerPool.Builder mergeAutoscalingSettings(AutoscalingSettings value)
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;

    • clearAutoscalingSettings

      public WorkerPool.Builder clearAutoscalingSettings()
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;

    • getAutoscalingSettingsBuilder

      public AutoscalingSettings.Builder getAutoscalingSettingsBuilder()
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;

    • getAutoscalingSettingsOrBuilder

      public AutoscalingSettingsOrBuilder getAutoscalingSettingsOrBuilder()
       Settings for autoscaling of this WorkerPool.
      .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
      Specified by:
      getAutoscalingSettingsOrBuilder in interface WorkerPoolOrBuilder

    • hasPoolArgs

      public boolean hasPoolArgs()
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;
      Specified by:
      hasPoolArgs in interface WorkerPoolOrBuilder
      Returns:
      Whether the poolArgs field is set.

    • getPoolArgs

      public com.google.protobuf.Any getPoolArgs()
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;
      Specified by:
      getPoolArgs in interface WorkerPoolOrBuilder
      Returns:
      The poolArgs.

    • setPoolArgs

      public WorkerPool.Builder setPoolArgs(com.google.protobuf.Any value)
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;

    • setPoolArgs

      public WorkerPool.Builder setPoolArgs(com.google.protobuf.Any.Builder builderForValue)
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;

    • mergePoolArgs

      public WorkerPool.Builder mergePoolArgs(com.google.protobuf.Any value)
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;

    • clearPoolArgs

      public WorkerPool.Builder clearPoolArgs()
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;

    • getPoolArgsBuilder

      public com.google.protobuf.Any.Builder getPoolArgsBuilder()
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;

    • getPoolArgsOrBuilder

      public com.google.protobuf.AnyOrBuilder getPoolArgsOrBuilder()
       Extra arguments for this worker pool.
      .google.protobuf.Any pool_args = 15;
      Specified by:
      getPoolArgsOrBuilder in interface WorkerPoolOrBuilder

    • getNetwork

      public String getNetwork()
       Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
      string network = 17;
      Specified by:
      getNetwork in interface WorkerPoolOrBuilder
      Returns:
      The network.

    • getNetworkBytes

      public com.google.protobuf.ByteString getNetworkBytes()
       Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
      string network = 17;
      Specified by:
      getNetworkBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for network.

    • setNetwork

      public WorkerPool.Builder setNetwork(String value)
       Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
      string network = 17;
      Parameters:
      value - The network to set.
      Returns:
      This builder for chaining.

    • clearNetwork

      public WorkerPool.Builder clearNetwork()
       Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
      string network = 17;
      Returns:
      This builder for chaining.

    • setNetworkBytes

      public WorkerPool.Builder setNetworkBytes(com.google.protobuf.ByteString value)
       Network to which VMs will be assigned.  If empty or unspecified,
 the service will use the network "default".
      string network = 17;
      Parameters:
      value - The bytes for network to set.
      Returns:
      This builder for chaining.

    • getSubnetwork

      public String getSubnetwork()
       Subnetwork to which VMs will be assigned, if desired.  Expected to be of
 the form "regions/REGION/subnetworks/SUBNETWORK".
      string subnetwork = 19;
      Specified by:
      getSubnetwork in interface WorkerPoolOrBuilder
      Returns:
      The subnetwork.

    • getSubnetworkBytes

      public com.google.protobuf.ByteString getSubnetworkBytes()
       Subnetwork to which VMs will be assigned, if desired.  Expected to be of
 the form "regions/REGION/subnetworks/SUBNETWORK".
      string subnetwork = 19;
      Specified by:
      getSubnetworkBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for subnetwork.

    • setSubnetwork

      public WorkerPool.Builder setSubnetwork(String value)
       Subnetwork to which VMs will be assigned, if desired.  Expected to be of
 the form "regions/REGION/subnetworks/SUBNETWORK".
      string subnetwork = 19;
      Parameters:
      value - The subnetwork to set.
      Returns:
      This builder for chaining.

    • clearSubnetwork

      public WorkerPool.Builder clearSubnetwork()
       Subnetwork to which VMs will be assigned, if desired.  Expected to be of
 the form "regions/REGION/subnetworks/SUBNETWORK".
      string subnetwork = 19;
      Returns:
      This builder for chaining.

    • setSubnetworkBytes

      public WorkerPool.Builder setSubnetworkBytes(com.google.protobuf.ByteString value)
       Subnetwork to which VMs will be assigned, if desired.  Expected to be of
 the form "regions/REGION/subnetworks/SUBNETWORK".
      string subnetwork = 19;
      Parameters:
      value - The bytes for subnetwork to set.
      Returns:
      This builder for chaining.

    • getWorkerHarnessContainerImage

      public String getWorkerHarnessContainerImage()
       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;
      Specified by:
      getWorkerHarnessContainerImage in interface WorkerPoolOrBuilder
      Returns:
      The workerHarnessContainerImage.

    • getWorkerHarnessContainerImageBytes

      public com.google.protobuf.ByteString getWorkerHarnessContainerImageBytes()
       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;
      Specified by:
      getWorkerHarnessContainerImageBytes in interface WorkerPoolOrBuilder
      Returns:
      The bytes for workerHarnessContainerImage.

    • setWorkerHarnessContainerImage

      public WorkerPool.Builder setWorkerHarnessContainerImage(String value)
       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;
      Parameters:
      value - The workerHarnessContainerImage to set.
      Returns:
      This builder for chaining.

    • clearWorkerHarnessContainerImage

      public WorkerPool.Builder clearWorkerHarnessContainerImage()
       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;
      Returns:
      This builder for chaining.

    • setWorkerHarnessContainerImageBytes

      public WorkerPool.Builder setWorkerHarnessContainerImageBytes(com.google.protobuf.ByteString value)
       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;
      Parameters:
      value - The bytes for workerHarnessContainerImage to set.
      Returns:
      This builder for chaining.

    • getNumThreadsPerWorker

      public int getNumThreadsPerWorker()
       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;
      Specified by:
      getNumThreadsPerWorker in interface WorkerPoolOrBuilder
      Returns:
      The numThreadsPerWorker.

    • setNumThreadsPerWorker

      public WorkerPool.Builder setNumThreadsPerWorker(int value)
       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;
      Parameters:
      value - The numThreadsPerWorker to set.
      Returns:
      This builder for chaining.

    • clearNumThreadsPerWorker

      public WorkerPool.Builder clearNumThreadsPerWorker()
       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;
      Returns:
      This builder for chaining.

    • getIpConfigurationValue

      public int getIpConfigurationValue()
       Configuration for VM IPs.
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
      Specified by:
      getIpConfigurationValue in interface WorkerPoolOrBuilder
      Returns:
      The enum numeric value on the wire for ipConfiguration.

    • setIpConfigurationValue

      public WorkerPool.Builder setIpConfigurationValue(int value)
       Configuration for VM IPs.
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
      Parameters:
      value - The enum numeric value on the wire for ipConfiguration to set.
      Returns:
      This builder for chaining.

    • getIpConfiguration

      public WorkerIPAddressConfiguration getIpConfiguration()
       Configuration for VM IPs.
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
      Specified by:
      getIpConfiguration in interface WorkerPoolOrBuilder
      Returns:
      The ipConfiguration.

    • setIpConfiguration

      public WorkerPool.Builder setIpConfiguration(WorkerIPAddressConfiguration value)
       Configuration for VM IPs.
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
      Parameters:
      value - The ipConfiguration to set.
      Returns:
      This builder for chaining.

    • clearIpConfiguration

      public WorkerPool.Builder clearIpConfiguration()
       Configuration for VM IPs.
      .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
      Returns:
      This builder for chaining.

    • getSdkHarnessContainerImagesList

      public List<SdkHarnessContainerImage> getSdkHarnessContainerImagesList()
       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;
      Specified by:
      getSdkHarnessContainerImagesList in interface WorkerPoolOrBuilder

    • getSdkHarnessContainerImagesCount

      public int getSdkHarnessContainerImagesCount()
       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;
      Specified by:
      getSdkHarnessContainerImagesCount in interface WorkerPoolOrBuilder

    • getSdkHarnessContainerImages

      public SdkHarnessContainerImage getSdkHarnessContainerImages(int 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;
      Specified by:
      getSdkHarnessContainerImages in interface WorkerPoolOrBuilder

    • setSdkHarnessContainerImages

      public WorkerPool.Builder setSdkHarnessContainerImages(int index, SdkHarnessContainerImage value)
       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;

    • setSdkHarnessContainerImages

      public WorkerPool.Builder setSdkHarnessContainerImages(int index, SdkHarnessContainerImage.Builder builderForValue)
       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;

    • addSdkHarnessContainerImages

      public WorkerPool.Builder addSdkHarnessContainerImages(SdkHarnessContainerImage value)
       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;

    • addSdkHarnessContainerImages

      public WorkerPool.Builder addSdkHarnessContainerImages(int index, SdkHarnessContainerImage value)
       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;

    • addSdkHarnessContainerImages

      public WorkerPool.Builder addSdkHarnessContainerImages(SdkHarnessContainerImage.Builder builderForValue)
       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;

    • addSdkHarnessContainerImages

      public WorkerPool.Builder addSdkHarnessContainerImages(int index, SdkHarnessContainerImage.Builder builderForValue)
       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;

    • addAllSdkHarnessContainerImages

      public WorkerPool.Builder addAllSdkHarnessContainerImages(Iterable<? extends SdkHarnessContainerImage> values)
       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;

    • clearSdkHarnessContainerImages

      public WorkerPool.Builder clearSdkHarnessContainerImages()
       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;

    • removeSdkHarnessContainerImages

      public WorkerPool.Builder removeSdkHarnessContainerImages(int 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;

    • getSdkHarnessContainerImagesBuilder

      public SdkHarnessContainerImage.Builder getSdkHarnessContainerImagesBuilder(int 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;

    • getSdkHarnessContainerImagesOrBuilder

      public SdkHarnessContainerImageOrBuilder getSdkHarnessContainerImagesOrBuilder(int 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;
      Specified by:
      getSdkHarnessContainerImagesOrBuilder in interface WorkerPoolOrBuilder

    • getSdkHarnessContainerImagesOrBuilderList

      public List<? extends SdkHarnessContainerImageOrBuilder> getSdkHarnessContainerImagesOrBuilderList()
       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;
      Specified by:
      getSdkHarnessContainerImagesOrBuilderList in interface WorkerPoolOrBuilder

    • addSdkHarnessContainerImagesBuilder

      public SdkHarnessContainerImage.Builder addSdkHarnessContainerImagesBuilder()
       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;

    • addSdkHarnessContainerImagesBuilder

      public SdkHarnessContainerImage.Builder addSdkHarnessContainerImagesBuilder(int 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;

    • getSdkHarnessContainerImagesBuilderList

      public List<SdkHarnessContainerImage.Builder> getSdkHarnessContainerImagesBuilderList()
       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;