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 class
WorkerPool.Builder
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.-
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 int
AUTOSCALING_SETTINGS_FIELD_NUMBER
static int
DATA_DISKS_FIELD_NUMBER
static int
DEFAULT_PACKAGE_SET_FIELD_NUMBER
static int
DISK_SIZE_GB_FIELD_NUMBER
static int
DISK_SOURCE_IMAGE_FIELD_NUMBER
static int
DISK_TYPE_FIELD_NUMBER
static int
IP_CONFIGURATION_FIELD_NUMBER
static int
KIND_FIELD_NUMBER
static int
MACHINE_TYPE_FIELD_NUMBER
static int
METADATA_FIELD_NUMBER
static int
NETWORK_FIELD_NUMBER
static int
NUM_THREADS_PER_WORKER_FIELD_NUMBER
static int
NUM_WORKERS_FIELD_NUMBER
static int
ON_HOST_MAINTENANCE_FIELD_NUMBER
static int
PACKAGES_FIELD_NUMBER
static int
POOL_ARGS_FIELD_NUMBER
static int
SDK_HARNESS_CONTAINER_IMAGES_FIELD_NUMBER
static int
SUBNETWORK_FIELD_NUMBER
static int
TASKRUNNER_SETTINGS_FIELD_NUMBER
static int
TEARDOWN_POLICY_FIELD_NUMBER
static int
WORKER_HARNESS_CONTAINER_IMAGE_FIELD_NUMBER
static int
ZONE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
containsMetadata(String key)
Metadata to set on the Google Compute Engine VMs.boolean
equals(Object obj)
AutoscalingSettings
getAutoscalingSettings()
Settings for autoscaling of this WorkerPool.AutoscalingSettingsOrBuilder
getAutoscalingSettingsOrBuilder()
Settings for autoscaling of this WorkerPool.Disk
getDataDisks(int index)
Data disks that are used by a VM in this workflow.int
getDataDisksCount()
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.DiskOrBuilder
getDataDisksOrBuilder(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 WorkerPool
getDefaultInstance()
WorkerPool
getDefaultInstanceForType()
DefaultPackageSet
getDefaultPackageSet()
The default package set to install.int
getDefaultPackageSetValue()
The default package set to install.static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
int
getDiskSizeGb()
Size of root disk for VMs, in GB.String
getDiskSourceImage()
Fully qualified source image for disks.com.google.protobuf.ByteString
getDiskSourceImageBytes()
Fully qualified source image for disks.String
getDiskType()
Type of root disk for VMs.com.google.protobuf.ByteString
getDiskTypeBytes()
Type of root disk for VMs.WorkerIPAddressConfiguration
getIpConfiguration()
Configuration for VM IPs.int
getIpConfigurationValue()
Configuration for VM IPs.String
getKind()
The kind of the worker pool; currently only `harness` and `shuffle` are supported.com.google.protobuf.ByteString
getKindBytes()
The kind of the worker pool; currently only `harness` and `shuffle` are supported.String
getMachineType()
Machine type (e.g.com.google.protobuf.ByteString
getMachineTypeBytes()
Machine type (e.g.Map<String,String>
getMetadata()
Deprecated.int
getMetadataCount()
Metadata to set on the Google Compute Engine VMs.Map<String,String>
getMetadataMap()
Metadata to set on the Google Compute Engine VMs.String
getMetadataOrDefault(String key, String defaultValue)
Metadata to set on the Google Compute Engine VMs.String
getMetadataOrThrow(String key)
Metadata to set on the Google Compute Engine VMs.String
getNetwork()
Network to which VMs will be assigned.com.google.protobuf.ByteString
getNetworkBytes()
Network to which VMs will be assigned.int
getNumThreadsPerWorker()
The number of threads per worker harness.int
getNumWorkers()
Number of Google Compute Engine workers in this pool needed to execute the job.String
getOnHostMaintenance()
The action to take on host maintenance, as defined by the Google Compute Engine API.com.google.protobuf.ByteString
getOnHostMaintenanceBytes()
The action to take on host maintenance, as defined by the Google Compute Engine API.Package
getPackages(int index)
Packages to be installed on workers.int
getPackagesCount()
Packages to be installed on workers.List<Package>
getPackagesList()
Packages to be installed on workers.PackageOrBuilder
getPackagesOrBuilder(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.Any
getPoolArgs()
Extra arguments for this worker pool.com.google.protobuf.AnyOrBuilder
getPoolArgsOrBuilder()
Extra arguments for this worker pool.SdkHarnessContainerImage
getSdkHarnessContainerImages(int index)
Set of SDK harness containers needed to execute this pipeline.int
getSdkHarnessContainerImagesCount()
Set of SDK harness containers needed to execute this pipeline.List<SdkHarnessContainerImage>
getSdkHarnessContainerImagesList()
Set of SDK harness containers needed to execute this pipeline.SdkHarnessContainerImageOrBuilder
getSdkHarnessContainerImagesOrBuilder(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.int
getSerializedSize()
String
getSubnetwork()
Subnetwork to which VMs will be assigned, if desired.com.google.protobuf.ByteString
getSubnetworkBytes()
Subnetwork to which VMs will be assigned, if desired.TaskRunnerSettings
getTaskrunnerSettings()
Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.TaskRunnerSettingsOrBuilder
getTaskrunnerSettingsOrBuilder()
Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.TeardownPolicy
getTeardownPolicy()
Sets the policy for determining when to turndown worker pool.int
getTeardownPolicyValue()
Sets the policy for determining when to turndown worker pool.String
getWorkerHarnessContainerImage()
Required.com.google.protobuf.ByteString
getWorkerHarnessContainerImageBytes()
Required.String
getZone()
Zone to run the worker pools in.com.google.protobuf.ByteString
getZoneBytes()
Zone to run the worker pools in.boolean
hasAutoscalingSettings()
Settings for autoscaling of this WorkerPool.int
hashCode()
boolean
hasPoolArgs()
Extra arguments for this worker pool.boolean
hasTaskrunnerSettings()
Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
protected com.google.protobuf.MapField
internalGetMapField(int number)
boolean
isInitialized()
static WorkerPool.Builder
newBuilder()
static WorkerPool.Builder
newBuilder(WorkerPool prototype)
WorkerPool.Builder
newBuilderForType()
protected WorkerPool.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static WorkerPool
parseDelimitedFrom(InputStream input)
static WorkerPool
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static WorkerPool
parseFrom(byte[] data)
static WorkerPool
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static WorkerPool
parseFrom(com.google.protobuf.ByteString data)
static WorkerPool
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static WorkerPool
parseFrom(com.google.protobuf.CodedInputStream input)
static WorkerPool
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static WorkerPool
parseFrom(InputStream input)
static WorkerPool
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static WorkerPool
parseFrom(ByteBuffer data)
static WorkerPool
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<WorkerPool>
parser()
WorkerPool.Builder
toBuilder()
void
writeTo(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:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetMapField
protected com.google.protobuf.MapField internalGetMapField(int number)
- Overrides:
internalGetMapField
in classcom.google.protobuf.GeneratedMessageV3
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in 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:
getKind
in 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:
getKindBytes
in 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:
getNumWorkers
in interfaceWorkerPoolOrBuilder
- 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 interfaceWorkerPoolOrBuilder
-
getPackagesOrBuilderList
public List<? extends PackageOrBuilder> getPackagesOrBuilderList()
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;
- Specified by:
getPackagesOrBuilderList
in interfaceWorkerPoolOrBuilder
-
getPackagesCount
public int getPackagesCount()
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;
- Specified by:
getPackagesCount
in interfaceWorkerPoolOrBuilder
-
getPackages
public Package getPackages(int index)
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;
- Specified by:
getPackages
in interfaceWorkerPoolOrBuilder
-
getPackagesOrBuilder
public PackageOrBuilder getPackagesOrBuilder(int index)
Packages to be installed on workers.
repeated .google.dataflow.v1beta3.Package packages = 3;
- Specified by:
getPackagesOrBuilder
in 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:
getDefaultPackageSetValue
in 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:
getDefaultPackageSet
in 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:
getMachineType
in 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:
getMachineTypeBytes
in 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:
getTeardownPolicyValue
in 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:
getTeardownPolicy
in 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:
getDiskSizeGb
in 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:
getDiskType
in 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:
getDiskTypeBytes
in interfaceWorkerPoolOrBuilder
- Returns:
- The bytes for diskType.
-
getDiskSourceImage
public String getDiskSourceImage()
Fully qualified source image for disks.
string disk_source_image = 8;
- Specified by:
getDiskSourceImage
in interfaceWorkerPoolOrBuilder
- 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 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:
getZone
in 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:
getZoneBytes
in 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:
hasTaskrunnerSettings
in 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:
getTaskrunnerSettings
in 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:
getTaskrunnerSettingsOrBuilder
in 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:
getOnHostMaintenance
in 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:
getOnHostMaintenanceBytes
in 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:
getDataDisksList
in 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:
getDataDisksOrBuilderList
in 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:
getDataDisksCount
in 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:
getDataDisks
in 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:
getDataDisksOrBuilder
in interfaceWorkerPoolOrBuilder
-
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 interfaceWorkerPoolOrBuilder
-
containsMetadata
public boolean containsMetadata(String key)
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;
- Specified by:
containsMetadata
in interfaceWorkerPoolOrBuilder
-
getMetadata
@Deprecated public Map<String,String> getMetadata()
Deprecated.UsegetMetadataMap()
instead.- Specified by:
getMetadata
in interfaceWorkerPoolOrBuilder
-
getMetadataMap
public Map<String,String> getMetadataMap()
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;
- Specified by:
getMetadataMap
in 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:
getMetadataOrDefault
in interfaceWorkerPoolOrBuilder
-
getMetadataOrThrow
public String getMetadataOrThrow(String key)
Metadata to set on the Google Compute Engine VMs.
map<string, string> metadata = 13;
- Specified by:
getMetadataOrThrow
in interfaceWorkerPoolOrBuilder
-
hasAutoscalingSettings
public boolean hasAutoscalingSettings()
Settings for autoscaling of this WorkerPool.
.google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
- Specified by:
hasAutoscalingSettings
in 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:
getAutoscalingSettings
in interfaceWorkerPoolOrBuilder
- Returns:
- The autoscalingSettings.
-
getAutoscalingSettingsOrBuilder
public AutoscalingSettingsOrBuilder getAutoscalingSettingsOrBuilder()
Settings for autoscaling of this WorkerPool.
.google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
- Specified by:
getAutoscalingSettingsOrBuilder
in interfaceWorkerPoolOrBuilder
-
hasPoolArgs
public boolean hasPoolArgs()
Extra arguments for this worker pool.
.google.protobuf.Any pool_args = 15;
- Specified by:
hasPoolArgs
in 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:
getPoolArgs
in 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:
getPoolArgsOrBuilder
in 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:
getNetwork
in 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:
getNetworkBytes
in 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:
getSubnetwork
in 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:
getSubnetworkBytes
in 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:
getWorkerHarnessContainerImage
in 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:
getWorkerHarnessContainerImageBytes
in 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:
getNumThreadsPerWorker
in interfaceWorkerPoolOrBuilder
- Returns:
- The numThreadsPerWorker.
-
getIpConfigurationValue
public int getIpConfigurationValue()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
- Specified by:
getIpConfigurationValue
in 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:
getIpConfiguration
in 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:
getSdkHarnessContainerImagesList
in 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:
getSdkHarnessContainerImagesOrBuilderList
in 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:
getSdkHarnessContainerImagesCount
in 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:
getSdkHarnessContainerImages
in 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:
getSdkHarnessContainerImagesOrBuilder
in interfaceWorkerPoolOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in 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:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in 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:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected WorkerPool.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in 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:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public WorkerPool getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-