Package com.google.dataflow.v1beta3
Class WorkerPool
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- 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
public final class WorkerPool extends com.google.protobuf.GeneratedMessageV3 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 typegoogle.dataflow.v1beta3.WorkerPool- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classWorkerPool.BuilderDescribes 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.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intAUTOSCALING_SETTINGS_FIELD_NUMBERstatic intDATA_DISKS_FIELD_NUMBERstatic intDEFAULT_PACKAGE_SET_FIELD_NUMBERstatic intDISK_SIZE_GB_FIELD_NUMBERstatic intDISK_SOURCE_IMAGE_FIELD_NUMBERstatic intDISK_TYPE_FIELD_NUMBERstatic intIP_CONFIGURATION_FIELD_NUMBERstatic intKIND_FIELD_NUMBERstatic intMACHINE_TYPE_FIELD_NUMBERstatic intMETADATA_FIELD_NUMBERstatic intNETWORK_FIELD_NUMBERstatic intNUM_THREADS_PER_WORKER_FIELD_NUMBERstatic intNUM_WORKERS_FIELD_NUMBERstatic intON_HOST_MAINTENANCE_FIELD_NUMBERstatic intPACKAGES_FIELD_NUMBERstatic intPOOL_ARGS_FIELD_NUMBERstatic intSDK_HARNESS_CONTAINER_IMAGES_FIELD_NUMBERstatic intSUBNETWORK_FIELD_NUMBERstatic intTASKRUNNER_SETTINGS_FIELD_NUMBERstatic intTEARDOWN_POLICY_FIELD_NUMBERstatic intWORKER_HARNESS_CONTAINER_IMAGE_FIELD_NUMBERstatic intZONE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description booleancontainsMetadata(String key)Metadata to set on the Google Compute Engine VMs.booleanequals(Object obj)AutoscalingSettingsgetAutoscalingSettings()Settings for autoscaling of this WorkerPool.AutoscalingSettingsOrBuildergetAutoscalingSettingsOrBuilder()Settings for autoscaling of this WorkerPool.DiskgetDataDisks(int index)Data disks that are used by a VM in this workflow.intgetDataDisksCount()Data disks that are used by a VM in this workflow.List<Disk>getDataDisksList()Data disks that are used by a VM in this workflow.DiskOrBuildergetDataDisksOrBuilder(int index)Data disks that are used by a VM in this workflow.List<? extends DiskOrBuilder>getDataDisksOrBuilderList()Data disks that are used by a VM in this workflow.static WorkerPoolgetDefaultInstance()WorkerPoolgetDefaultInstanceForType()DefaultPackageSetgetDefaultPackageSet()The default package set to install.intgetDefaultPackageSetValue()The default package set to install.static com.google.protobuf.Descriptors.DescriptorgetDescriptor()intgetDiskSizeGb()Size of root disk for VMs, in GB.StringgetDiskSourceImage()Fully qualified source image for disks.com.google.protobuf.ByteStringgetDiskSourceImageBytes()Fully qualified source image for disks.StringgetDiskType()Type of root disk for VMs.com.google.protobuf.ByteStringgetDiskTypeBytes()Type of root disk for VMs.WorkerIPAddressConfigurationgetIpConfiguration()Configuration for VM IPs.intgetIpConfigurationValue()Configuration for VM IPs.StringgetKind()The kind of the worker pool; currently only `harness` and `shuffle` are supported.com.google.protobuf.ByteStringgetKindBytes()The kind of the worker pool; currently only `harness` and `shuffle` are supported.StringgetMachineType()Machine type (e.g.com.google.protobuf.ByteStringgetMachineTypeBytes()Machine type (e.g.Map<String,String>getMetadata()Deprecated.intgetMetadataCount()Metadata to set on the Google Compute Engine VMs.Map<String,String>getMetadataMap()Metadata to set on the Google Compute Engine VMs.StringgetMetadataOrDefault(String key, String defaultValue)Metadata to set on the Google Compute Engine VMs.StringgetMetadataOrThrow(String key)Metadata to set on the Google Compute Engine VMs.StringgetNetwork()Network to which VMs will be assigned.com.google.protobuf.ByteStringgetNetworkBytes()Network to which VMs will be assigned.intgetNumThreadsPerWorker()The number of threads per worker harness.intgetNumWorkers()Number of Google Compute Engine workers in this pool needed to execute the job.StringgetOnHostMaintenance()The action to take on host maintenance, as defined by the Google Compute Engine API.com.google.protobuf.ByteStringgetOnHostMaintenanceBytes()The action to take on host maintenance, as defined by the Google Compute Engine API.PackagegetPackages(int index)Packages to be installed on workers.intgetPackagesCount()Packages to be installed on workers.List<Package>getPackagesList()Packages to be installed on workers.PackageOrBuildergetPackagesOrBuilder(int index)Packages to be installed on workers.List<? extends PackageOrBuilder>getPackagesOrBuilderList()Packages to be installed on workers.com.google.protobuf.Parser<WorkerPool>getParserForType()com.google.protobuf.AnygetPoolArgs()Extra arguments for this worker pool.com.google.protobuf.AnyOrBuildergetPoolArgsOrBuilder()Extra arguments for this worker pool.SdkHarnessContainerImagegetSdkHarnessContainerImages(int index)Set of SDK harness containers needed to execute this pipeline.intgetSdkHarnessContainerImagesCount()Set of SDK harness containers needed to execute this pipeline.List<SdkHarnessContainerImage>getSdkHarnessContainerImagesList()Set of SDK harness containers needed to execute this pipeline.SdkHarnessContainerImageOrBuildergetSdkHarnessContainerImagesOrBuilder(int index)Set of SDK harness containers needed to execute this pipeline.List<? extends SdkHarnessContainerImageOrBuilder>getSdkHarnessContainerImagesOrBuilderList()Set of SDK harness containers needed to execute this pipeline.intgetSerializedSize()StringgetSubnetwork()Subnetwork to which VMs will be assigned, if desired.com.google.protobuf.ByteStringgetSubnetworkBytes()Subnetwork to which VMs will be assigned, if desired.TaskRunnerSettingsgetTaskrunnerSettings()Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.TaskRunnerSettingsOrBuildergetTaskrunnerSettingsOrBuilder()Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.TeardownPolicygetTeardownPolicy()Sets the policy for determining when to turndown worker pool.intgetTeardownPolicyValue()Sets the policy for determining when to turndown worker pool.StringgetWorkerHarnessContainerImage()Required.com.google.protobuf.ByteStringgetWorkerHarnessContainerImageBytes()Required.StringgetZone()Zone to run the worker pools in.com.google.protobuf.ByteStringgetZoneBytes()Zone to run the worker pools in.booleanhasAutoscalingSettings()Settings for autoscaling of this WorkerPool.inthashCode()booleanhasPoolArgs()Extra arguments for this worker pool.booleanhasTaskrunnerSettings()Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()protected com.google.protobuf.MapFieldinternalGetMapField(int number)booleanisInitialized()static WorkerPool.BuildernewBuilder()static WorkerPool.BuildernewBuilder(WorkerPool prototype)WorkerPool.BuildernewBuilderForType()protected WorkerPool.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static WorkerPoolparseDelimitedFrom(InputStream input)static WorkerPoolparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static WorkerPoolparseFrom(byte[] data)static WorkerPoolparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static WorkerPoolparseFrom(com.google.protobuf.ByteString data)static WorkerPoolparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static WorkerPoolparseFrom(com.google.protobuf.CodedInputStream input)static WorkerPoolparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static WorkerPoolparseFrom(InputStream input)static WorkerPoolparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static WorkerPoolparseFrom(ByteBuffer data)static WorkerPoolparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<WorkerPool>parser()WorkerPool.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
KIND_FIELD_NUMBER
public static final int KIND_FIELD_NUMBER
- See Also:
- Constant Field Values
-
NUM_WORKERS_FIELD_NUMBER
public static final int NUM_WORKERS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PACKAGES_FIELD_NUMBER
public static final int PACKAGES_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DEFAULT_PACKAGE_SET_FIELD_NUMBER
public static final int DEFAULT_PACKAGE_SET_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MACHINE_TYPE_FIELD_NUMBER
public static final int MACHINE_TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TEARDOWN_POLICY_FIELD_NUMBER
public static final int TEARDOWN_POLICY_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DISK_SIZE_GB_FIELD_NUMBER
public static final int DISK_SIZE_GB_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DISK_TYPE_FIELD_NUMBER
public static final int DISK_TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DISK_SOURCE_IMAGE_FIELD_NUMBER
public static final int DISK_SOURCE_IMAGE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ZONE_FIELD_NUMBER
public static final int ZONE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TASKRUNNER_SETTINGS_FIELD_NUMBER
public static final int TASKRUNNER_SETTINGS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ON_HOST_MAINTENANCE_FIELD_NUMBER
public static final int ON_HOST_MAINTENANCE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DATA_DISKS_FIELD_NUMBER
public static final int DATA_DISKS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
METADATA_FIELD_NUMBER
public static final int METADATA_FIELD_NUMBER
- See Also:
- Constant Field Values
-
AUTOSCALING_SETTINGS_FIELD_NUMBER
public static final int AUTOSCALING_SETTINGS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
POOL_ARGS_FIELD_NUMBER
public static final int POOL_ARGS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
NETWORK_FIELD_NUMBER
public static final int NETWORK_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SUBNETWORK_FIELD_NUMBER
public static final int SUBNETWORK_FIELD_NUMBER
- See Also:
- Constant Field Values
-
WORKER_HARNESS_CONTAINER_IMAGE_FIELD_NUMBER
public static final int WORKER_HARNESS_CONTAINER_IMAGE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
NUM_THREADS_PER_WORKER_FIELD_NUMBER
public static final int NUM_THREADS_PER_WORKER_FIELD_NUMBER
- See Also:
- Constant Field Values
-
IP_CONFIGURATION_FIELD_NUMBER
public static final int IP_CONFIGURATION_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SDK_HARNESS_CONTAINER_IMAGES_FIELD_NUMBER
public static final int SDK_HARNESS_CONTAINER_IMAGES_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetMapField
protected com.google.protobuf.MapField internalGetMapField(int number)
- Overrides:
internalGetMapFieldin classcom.google.protobuf.GeneratedMessageV3
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3
-
getKind
public String getKind()
The kind of the worker pool; currently only `harness` and `shuffle` are supported.
string kind = 1;- Specified by:
getKindin interfaceWorkerPoolOrBuilder- 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:
getKindBytesin interfaceWorkerPoolOrBuilder- 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:
getNumWorkersin interfaceWorkerPoolOrBuilder- Returns:
- The numWorkers.
-
getPackagesList
public List<Package> getPackagesList()
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;- Specified by:
getPackagesListin interfaceWorkerPoolOrBuilder
-
getPackagesOrBuilderList
public List<? extends PackageOrBuilder> getPackagesOrBuilderList()
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;- Specified by:
getPackagesOrBuilderListin interfaceWorkerPoolOrBuilder
-
getPackagesCount
public int getPackagesCount()
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;- Specified by:
getPackagesCountin interfaceWorkerPoolOrBuilder
-
getPackages
public Package getPackages(int index)
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;- Specified by:
getPackagesin interfaceWorkerPoolOrBuilder
-
getPackagesOrBuilder
public PackageOrBuilder getPackagesOrBuilder(int index)
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;- Specified by:
getPackagesOrBuilderin interfaceWorkerPoolOrBuilder
-
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:
getDefaultPackageSetValuein interfaceWorkerPoolOrBuilder- 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:
getDefaultPackageSetin interfaceWorkerPoolOrBuilder- 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:
getMachineTypein interfaceWorkerPoolOrBuilder- 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:
getMachineTypeBytesin interfaceWorkerPoolOrBuilder- 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:
getTeardownPolicyValuein interfaceWorkerPoolOrBuilder- 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:
getTeardownPolicyin interfaceWorkerPoolOrBuilder- 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:
getDiskSizeGbin interfaceWorkerPoolOrBuilder- 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:
getDiskTypein interfaceWorkerPoolOrBuilder- 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:
getDiskTypeBytesin interfaceWorkerPoolOrBuilder- Returns:
- The bytes for diskType.
-
getDiskSourceImage
public String getDiskSourceImage()
Fully qualified source image for disks.
string disk_source_image = 8;- Specified by:
getDiskSourceImagein interfaceWorkerPoolOrBuilder- Returns:
- The diskSourceImage.
-
getDiskSourceImageBytes
public com.google.protobuf.ByteString getDiskSourceImageBytes()
Fully qualified source image for disks.
string disk_source_image = 8;- Specified by:
getDiskSourceImageBytesin interfaceWorkerPoolOrBuilder- 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:
getZonein interfaceWorkerPoolOrBuilder- 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:
getZoneBytesin interfaceWorkerPoolOrBuilder- 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:
hasTaskrunnerSettingsin interfaceWorkerPoolOrBuilder- 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:
getTaskrunnerSettingsin interfaceWorkerPoolOrBuilder- 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:
getTaskrunnerSettingsOrBuilderin interfaceWorkerPoolOrBuilder
-
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:
getOnHostMaintenancein interfaceWorkerPoolOrBuilder- 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:
getOnHostMaintenanceBytesin interfaceWorkerPoolOrBuilder- 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:
getDataDisksListin interfaceWorkerPoolOrBuilder
-
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:
getDataDisksOrBuilderListin interfaceWorkerPoolOrBuilder
-
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:
getDataDisksCountin interfaceWorkerPoolOrBuilder
-
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:
getDataDisksin interfaceWorkerPoolOrBuilder
-
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:
getDataDisksOrBuilderin interfaceWorkerPoolOrBuilder
-
getMetadataCount
public int getMetadataCount()
Description copied from interface:WorkerPoolOrBuilderMetadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;- Specified by:
getMetadataCountin interfaceWorkerPoolOrBuilder
-
containsMetadata
public boolean containsMetadata(String key)
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;- Specified by:
containsMetadatain interfaceWorkerPoolOrBuilder
-
getMetadata
@Deprecated public Map<String,String> getMetadata()
Deprecated.UsegetMetadataMap()instead.- Specified by:
getMetadatain interfaceWorkerPoolOrBuilder
-
getMetadataMap
public Map<String,String> getMetadataMap()
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;- Specified by:
getMetadataMapin interfaceWorkerPoolOrBuilder
-
getMetadataOrDefault
public String getMetadataOrDefault(String key, String defaultValue)
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;- Specified by:
getMetadataOrDefaultin interfaceWorkerPoolOrBuilder
-
getMetadataOrThrow
public String getMetadataOrThrow(String key)
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;- Specified by:
getMetadataOrThrowin interfaceWorkerPoolOrBuilder
-
hasAutoscalingSettings
public boolean hasAutoscalingSettings()
Settings for autoscaling of this WorkerPool.
.google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;- Specified by:
hasAutoscalingSettingsin interfaceWorkerPoolOrBuilder- 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:
getAutoscalingSettingsin interfaceWorkerPoolOrBuilder- Returns:
- The autoscalingSettings.
-
getAutoscalingSettingsOrBuilder
public AutoscalingSettingsOrBuilder getAutoscalingSettingsOrBuilder()
Settings for autoscaling of this WorkerPool.
.google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;- Specified by:
getAutoscalingSettingsOrBuilderin interfaceWorkerPoolOrBuilder
-
hasPoolArgs
public boolean hasPoolArgs()
Extra arguments for this worker pool.
.google.protobuf.Any pool_args = 15;- Specified by:
hasPoolArgsin interfaceWorkerPoolOrBuilder- 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:
getPoolArgsin interfaceWorkerPoolOrBuilder- Returns:
- The poolArgs.
-
getPoolArgsOrBuilder
public com.google.protobuf.AnyOrBuilder getPoolArgsOrBuilder()
Extra arguments for this worker pool.
.google.protobuf.Any pool_args = 15;- Specified by:
getPoolArgsOrBuilderin interfaceWorkerPoolOrBuilder
-
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:
getNetworkin interfaceWorkerPoolOrBuilder- 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:
getNetworkBytesin interfaceWorkerPoolOrBuilder- 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:
getSubnetworkin interfaceWorkerPoolOrBuilder- 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:
getSubnetworkBytesin interfaceWorkerPoolOrBuilder- 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:
getWorkerHarnessContainerImagein interfaceWorkerPoolOrBuilder- 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:
getWorkerHarnessContainerImageBytesin interfaceWorkerPoolOrBuilder- 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:
getNumThreadsPerWorkerin interfaceWorkerPoolOrBuilder- Returns:
- The numThreadsPerWorker.
-
getIpConfigurationValue
public int getIpConfigurationValue()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;- Specified by:
getIpConfigurationValuein interfaceWorkerPoolOrBuilder- 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:
getIpConfigurationin interfaceWorkerPoolOrBuilder- 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:
getSdkHarnessContainerImagesListin interfaceWorkerPoolOrBuilder
-
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:
getSdkHarnessContainerImagesOrBuilderListin interfaceWorkerPoolOrBuilder
-
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:
getSdkHarnessContainerImagesCountin interfaceWorkerPoolOrBuilder
-
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:
getSdkHarnessContainerImagesin interfaceWorkerPoolOrBuilder
-
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:
getSdkHarnessContainerImagesOrBuilderin interfaceWorkerPoolOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.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:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static WorkerPool.Builder newBuilder()
-
newBuilder
public static WorkerPool.Builder newBuilder(WorkerPool prototype)
-
toBuilder
public WorkerPool.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected WorkerPool.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static WorkerPool getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<WorkerPool> parser()
-
getParserForType
public com.google.protobuf.Parser<WorkerPool> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public WorkerPool getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-