getPackagesList();
/**
*
*
*
* Packages to be installed on workers.
*
*
* repeated .google.dataflow.v1beta3.Package packages = 3;
*/
com.google.dataflow.v1beta3.Package getPackages(int index);
/**
*
*
*
* Packages to be installed on workers.
*
*
* repeated .google.dataflow.v1beta3.Package packages = 3;
*/
int getPackagesCount();
/**
*
*
*
* Packages to be installed on workers.
*
*
* repeated .google.dataflow.v1beta3.Package packages = 3;
*/
java.util.List getPackagesOrBuilderList();
/**
*
*
*
* Packages to be installed on workers.
*
*
* repeated .google.dataflow.v1beta3.Package packages = 3;
*/
com.google.dataflow.v1beta3.PackageOrBuilder getPackagesOrBuilder(int index);
/**
*
*
*
* The default package set to install. This allows the service to
* select a default set of packages which are useful to worker
* harnesses written in a particular language.
*
*
* .google.dataflow.v1beta3.DefaultPackageSet default_package_set = 4;
*
* @return The enum numeric value on the wire for defaultPackageSet.
*/
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;
*
* @return The defaultPackageSet.
*/
com.google.dataflow.v1beta3.DefaultPackageSet getDefaultPackageSet();
/**
*
*
*
* Machine type (e.g. "n1-standard-1"). If empty or unspecified, the
* service will attempt to choose a reasonable default.
*
*
* string machine_type = 5;
*
* @return The machineType.
*/
java.lang.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;
*
* @return The bytes for machineType.
*/
com.google.protobuf.ByteString getMachineTypeBytes();
/**
*
*
*
* Sets the policy for determining when to turndown worker pool.
* Allowed values are: `TEARDOWN_ALWAYS`, `TEARDOWN_ON_SUCCESS`, and
* `TEARDOWN_NEVER`.
* `TEARDOWN_ALWAYS` means workers are always torn down regardless of whether
* the job succeeds. `TEARDOWN_ON_SUCCESS` means workers are torn down
* if the job succeeds. `TEARDOWN_NEVER` means the workers are never torn
* down.
* If the workers are not torn down by the service, they will
* continue to run and use Google Compute Engine VM resources in the
* user's project until they are explicitly terminated by the user.
* Because of this, Google recommends using the `TEARDOWN_ALWAYS`
* policy except for small, manually supervised test jobs.
* If unknown or unspecified, the service will attempt to choose a reasonable
* default.
*
*
* .google.dataflow.v1beta3.TeardownPolicy teardown_policy = 6;
*
* @return The enum numeric value on the wire for teardownPolicy.
*/
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;
*
* @return The teardownPolicy.
*/
com.google.dataflow.v1beta3.TeardownPolicy getTeardownPolicy();
/**
*
*
*
* Size of root disk for VMs, in GB. If zero or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* int32 disk_size_gb = 7;
*
* @return The diskSizeGb.
*/
int getDiskSizeGb();
/**
*
*
*
* Type of root disk for VMs. If empty or unspecified, the service will
* attempt to choose a reasonable default.
*
*
* string disk_type = 16;
*
* @return The diskType.
*/
java.lang.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;
*
* @return The bytes for diskType.
*/
com.google.protobuf.ByteString getDiskTypeBytes();
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @return The diskSourceImage.
*/
java.lang.String getDiskSourceImage();
/**
*
*
*
* Fully qualified source image for disks.
*
*
* string disk_source_image = 8;
*
* @return The bytes for diskSourceImage.
*/
com.google.protobuf.ByteString getDiskSourceImageBytes();
/**
*
*
*
* Zone to run the worker pools in. If empty or unspecified, the service
* will attempt to choose a reasonable default.
*
*
* string zone = 9;
*
* @return The zone.
*/
java.lang.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;
*
* @return The bytes for zone.
*/
com.google.protobuf.ByteString getZoneBytes();
/**
*
*
*
* Settings passed through to Google Compute Engine workers when
* using the standard Dataflow task runner. Users should ignore
* this field.
*
*
* .google.dataflow.v1beta3.TaskRunnerSettings taskrunner_settings = 10;
*
* @return Whether the taskrunnerSettings field is set.
*/
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;
*
* @return The taskrunnerSettings.
*/
com.google.dataflow.v1beta3.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;
*/
com.google.dataflow.v1beta3.TaskRunnerSettingsOrBuilder getTaskrunnerSettingsOrBuilder();
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @return The onHostMaintenance.
*/
java.lang.String getOnHostMaintenance();
/**
*
*
*
* The action to take on host maintenance, as defined by the Google
* Compute Engine API.
*
*
* string on_host_maintenance = 11;
*
* @return The bytes for onHostMaintenance.
*/
com.google.protobuf.ByteString getOnHostMaintenanceBytes();
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
java.util.List getDataDisksList();
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
com.google.dataflow.v1beta3.Disk getDataDisks(int index);
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
int getDataDisksCount();
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
java.util.List getDataDisksOrBuilderList();
/**
*
*
*
* Data disks that are used by a VM in this workflow.
*
*
* repeated .google.dataflow.v1beta3.Disk data_disks = 12;
*/
com.google.dataflow.v1beta3.DiskOrBuilder getDataDisksOrBuilder(int index);
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
int getMetadataCount();
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
boolean containsMetadata(java.lang.String key);
/** Use {@link #getMetadataMap()} instead. */
@java.lang.Deprecated
java.util.Map getMetadata();
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
java.util.Map getMetadataMap();
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
/* nullable */
java.lang.String getMetadataOrDefault(
java.lang.String key,
/* nullable */
java.lang.String defaultValue);
/**
*
*
*
* Metadata to set on the Google Compute Engine VMs.
*
*
* map<string, string> metadata = 13;
*/
java.lang.String getMetadataOrThrow(java.lang.String key);
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*
* @return Whether the autoscalingSettings field is set.
*/
boolean hasAutoscalingSettings();
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*
* @return The autoscalingSettings.
*/
com.google.dataflow.v1beta3.AutoscalingSettings getAutoscalingSettings();
/**
*
*
*
* Settings for autoscaling of this WorkerPool.
*
*
* .google.dataflow.v1beta3.AutoscalingSettings autoscaling_settings = 14;
*/
com.google.dataflow.v1beta3.AutoscalingSettingsOrBuilder getAutoscalingSettingsOrBuilder();
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*
* @return Whether the poolArgs field is set.
*/
boolean hasPoolArgs();
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*
* @return The poolArgs.
*/
com.google.protobuf.Any getPoolArgs();
/**
*
*
*
* Extra arguments for this worker pool.
*
*
* .google.protobuf.Any pool_args = 15;
*/
com.google.protobuf.AnyOrBuilder getPoolArgsOrBuilder();
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 17;
*
* @return The network.
*/
java.lang.String getNetwork();
/**
*
*
*
* Network to which VMs will be assigned. If empty or unspecified,
* the service will use the network "default".
*
*
* string network = 17;
*
* @return The bytes for network.
*/
com.google.protobuf.ByteString getNetworkBytes();
/**
*
*
*
* Subnetwork to which VMs will be assigned, if desired. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @return The subnetwork.
*/
java.lang.String getSubnetwork();
/**
*
*
*
* Subnetwork to which VMs will be assigned, if desired. Expected to be of
* the form "regions/REGION/subnetworks/SUBNETWORK".
*
*
* string subnetwork = 19;
*
* @return The bytes for subnetwork.
*/
com.google.protobuf.ByteString getSubnetworkBytes();
/**
*
*
*
* Required. Docker container image that executes the Cloud Dataflow worker
* harness, residing in Google Container Registry.
* Deprecated for the Fn API path. Use sdk_harness_container_images instead.
*
*
* string worker_harness_container_image = 18;
*
* @return The workerHarnessContainerImage.
*/
java.lang.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;
*
* @return The bytes for workerHarnessContainerImage.
*/
com.google.protobuf.ByteString getWorkerHarnessContainerImageBytes();
/**
*
*
*
* The number of threads per worker harness. If empty or unspecified, the
* service will choose a number of threads (according to the number of cores
* on the selected machine type for batch, or 1 by convention for streaming).
*
*
* int32 num_threads_per_worker = 20;
*
* @return The numThreadsPerWorker.
*/
int getNumThreadsPerWorker();
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
*
* @return The enum numeric value on the wire for ipConfiguration.
*/
int getIpConfigurationValue();
/**
*
*
*
* Configuration for VM IPs.
*
*
* .google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 21;
*
* @return The ipConfiguration.
*/
com.google.dataflow.v1beta3.WorkerIPAddressConfiguration getIpConfiguration();
/**
*
*
*
* 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;
*
*/
java.util.List
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;
*
*/
com.google.dataflow.v1beta3.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;
*
*/
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;
*
*/
java.util.List
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;
*
*/
com.google.dataflow.v1beta3.SdkHarnessContainerImageOrBuilder
getSdkHarnessContainerImagesOrBuilder(int index);
}