Package com.google.dataflow.v1beta3

Class WorkerPool

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
com.google.dataflow.v1beta3.WorkerPool
All Implemented Interfaces:
WorkerPoolOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable
@Generated public final class WorkerPool extends com.google.protobuf.GeneratedMessage 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
See Also:

  • Field Details

    • KIND_FIELD_NUMBER

      public static final int KIND_FIELD_NUMBER
      See Also:

    • NUM_WORKERS_FIELD_NUMBER

      public static final int NUM_WORKERS_FIELD_NUMBER
      See Also:

    • PACKAGES_FIELD_NUMBER

      public static final int PACKAGES_FIELD_NUMBER
      See Also:

    • DEFAULT_PACKAGE_SET_FIELD_NUMBER

      public static final int DEFAULT_PACKAGE_SET_FIELD_NUMBER
      See Also:

    • MACHINE_TYPE_FIELD_NUMBER

      public static final int MACHINE_TYPE_FIELD_NUMBER
      See Also:

    • TEARDOWN_POLICY_FIELD_NUMBER

      public static final int TEARDOWN_POLICY_FIELD_NUMBER
      See Also:

    • DISK_SIZE_GB_FIELD_NUMBER

      public static final int DISK_SIZE_GB_FIELD_NUMBER
      See Also:

    • DISK_TYPE_FIELD_NUMBER

      public static final int DISK_TYPE_FIELD_NUMBER
      See Also:

    • DISK_PROVISIONED_IOPS_FIELD_NUMBER

      public static final int DISK_PROVISIONED_IOPS_FIELD_NUMBER
      See Also:

    • DISK_PROVISIONED_THROUGHPUT_MIBPS_FIELD_NUMBER

      public static final int DISK_PROVISIONED_THROUGHPUT_MIBPS_FIELD_NUMBER
      See Also:

    • DISK_SOURCE_IMAGE_FIELD_NUMBER

      public static final int DISK_SOURCE_IMAGE_FIELD_NUMBER
      See Also:

    • ZONE_FIELD_NUMBER

      public static final int ZONE_FIELD_NUMBER
      See Also:

    • TASKRUNNER_SETTINGS_FIELD_NUMBER

      public static final int TASKRUNNER_SETTINGS_FIELD_NUMBER
      See Also:

    • ON_HOST_MAINTENANCE_FIELD_NUMBER

      public static final int ON_HOST_MAINTENANCE_FIELD_NUMBER
      See Also:

    • DATA_DISKS_FIELD_NUMBER

      public static final int DATA_DISKS_FIELD_NUMBER
      See Also:

    • METADATA_FIELD_NUMBER

      public static final int METADATA_FIELD_NUMBER
      See Also:

    • AUTOSCALING_SETTINGS_FIELD_NUMBER

      public static final int AUTOSCALING_SETTINGS_FIELD_NUMBER
      See Also:

    • POOL_ARGS_FIELD_NUMBER

      public static final int POOL_ARGS_FIELD_NUMBER
      See Also:

    • NETWORK_FIELD_NUMBER

      public static final int NETWORK_FIELD_NUMBER
      See Also:

    • SUBNETWORK_FIELD_NUMBER

      public static final int SUBNETWORK_FIELD_NUMBER
      See Also:

    • WORKER_HARNESS_CONTAINER_IMAGE_FIELD_NUMBER

      public static final int WORKER_HARNESS_CONTAINER_IMAGE_FIELD_NUMBER
      See Also:

    • NUM_THREADS_PER_WORKER_FIELD_NUMBER

      public static final int NUM_THREADS_PER_WORKER_FIELD_NUMBER
      See Also:

    • IP_CONFIGURATION_FIELD_NUMBER

      public static final int IP_CONFIGURATION_FIELD_NUMBER
      See Also:

    • SDK_HARNESS_CONTAINER_IMAGES_FIELD_NUMBER

      public static final int SDK_HARNESS_CONTAINER_IMAGES_FIELD_NUMBER
      See Also:

  • 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

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

    • 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.

    • 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.

    • getPackagesList

      public List<Package> getPackagesList()
       Packages to be installed on workers.
      repeated .google.dataflow.v1beta3.Package packages = 3;
      Specified by:
      getPackagesList 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

    • 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

    • 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

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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

    • 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

    • 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

    • 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

    • 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

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • 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.

    • getIpConfiguration

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

    • 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

    • 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

    • 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

    • 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

    • isInitialized

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

    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage

    • parseFrom

      public static WorkerPool parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static WorkerPool parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static WorkerPool parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static WorkerPool parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static WorkerPool parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static WorkerPool parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static WorkerPool parseFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static WorkerPool parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static WorkerPool parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static WorkerPool parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseFrom

      public static WorkerPool parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static WorkerPool parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • newBuilderForType

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

    • newBuilder

      public static WorkerPool.Builder newBuilder()

    • newBuilder

      public static WorkerPool.Builder newBuilder(WorkerPool prototype)

    • toBuilder

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

    • newBuilderForType

      protected WorkerPool.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • getDefaultInstance

      public static WorkerPool getDefaultInstance()

    • parser

      public static com.google.protobuf.Parser<WorkerPool> parser()

    • getParserForType

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

    • getDefaultInstanceForType

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