Uses of Class
com.google.dataflow.v1beta3.WorkerPool.Builder
-
Uses of WorkerPool.Builder in com.google.dataflow.v1beta3
Methods in com.google.dataflow.v1beta3 that return WorkerPool.BuilderModifier and TypeMethodDescriptionWorkerPool.Builder.addAllDataDisks(Iterable<? extends Disk> values) Data disks that are used by a VM in this workflow.WorkerPool.Builder.addAllPackages(Iterable<? extends Package> values) Packages to be installed on workers.WorkerPool.Builder.addAllSdkHarnessContainerImages(Iterable<? extends SdkHarnessContainerImage> values) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.addDataDisks(int index, Disk value) Data disks that are used by a VM in this workflow.WorkerPool.Builder.addDataDisks(int index, Disk.Builder builderForValue) Data disks that are used by a VM in this workflow.WorkerPool.Builder.addDataDisks(Disk value) Data disks that are used by a VM in this workflow.WorkerPool.Builder.addDataDisks(Disk.Builder builderForValue) Data disks that are used by a VM in this workflow.WorkerPool.Builder.addPackages(int index, Package value) Packages to be installed on workers.WorkerPool.Builder.addPackages(int index, Package.Builder builderForValue) Packages to be installed on workers.WorkerPool.Builder.addPackages(Package value) Packages to be installed on workers.WorkerPool.Builder.addPackages(Package.Builder builderForValue) Packages to be installed on workers.WorkerPool.Builder.addSdkHarnessContainerImages(int index, SdkHarnessContainerImage value) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.addSdkHarnessContainerImages(int index, SdkHarnessContainerImage.Builder builderForValue) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.addSdkHarnessContainerImages(SdkHarnessContainerImage value) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.addSdkHarnessContainerImages(SdkHarnessContainerImage.Builder builderForValue) Set of SDK harness containers needed to execute this pipeline.Environment.Builder.addWorkerPoolsBuilder()The worker pools.Environment.Builder.addWorkerPoolsBuilder(int index) The worker pools.WorkerPool.Builder.clear()WorkerPool.Builder.clearAutoscalingSettings()Settings for autoscaling of this WorkerPool.WorkerPool.Builder.clearDataDisks()Data disks that are used by a VM in this workflow.WorkerPool.Builder.clearDefaultPackageSet()The default package set to install.WorkerPool.Builder.clearDiskProvisionedIops()Optional.WorkerPool.Builder.clearDiskProvisionedThroughputMibps()Optional.WorkerPool.Builder.clearDiskSizeGb()Size of root disk for VMs, in GB.WorkerPool.Builder.clearDiskSourceImage()Fully qualified source image for disks.WorkerPool.Builder.clearDiskType()Type of root disk for VMs.WorkerPool.Builder.clearIpConfiguration()Configuration for VM IPs.WorkerPool.Builder.clearKind()The kind of the worker pool; currently only `harness` and `shuffle` are supported.WorkerPool.Builder.clearMachineType()Machine type (e.g.WorkerPool.Builder.clearMetadata()WorkerPool.Builder.clearNetwork()Network to which VMs will be assigned.WorkerPool.Builder.clearNumThreadsPerWorker()The number of threads per worker harness.WorkerPool.Builder.clearNumWorkers()Number of Google Compute Engine workers in this pool needed to execute the job.WorkerPool.Builder.clearOnHostMaintenance()The action to take on host maintenance, as defined by the Google Compute Engine API.WorkerPool.Builder.clearPackages()Packages to be installed on workers.WorkerPool.Builder.clearPoolArgs()Extra arguments for this worker pool.WorkerPool.Builder.clearSdkHarnessContainerImages()Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.clearSubnetwork()Subnetwork to which VMs will be assigned, if desired.WorkerPool.Builder.clearTaskrunnerSettings()Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.WorkerPool.Builder.clearTeardownPolicy()Sets the policy for determining when to turndown worker pool.WorkerPool.Builder.clearWorkerHarnessContainerImage()Required.WorkerPool.Builder.clearZone()Zone to run the worker pools in.Environment.Builder.getWorkerPoolsBuilder(int index) The worker pools.WorkerPool.Builder.mergeAutoscalingSettings(AutoscalingSettings value) Settings for autoscaling of this WorkerPool.WorkerPool.Builder.mergeFrom(WorkerPool other) WorkerPool.Builder.mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) WorkerPool.Builder.mergeFrom(com.google.protobuf.Message other) WorkerPool.Builder.mergePoolArgs(com.google.protobuf.Any value) Extra arguments for this worker pool.WorkerPool.Builder.mergeTaskrunnerSettings(TaskRunnerSettings value) Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.static WorkerPool.BuilderWorkerPool.newBuilder()static WorkerPool.BuilderWorkerPool.newBuilder(WorkerPool prototype) WorkerPool.newBuilderForType()protected WorkerPool.BuilderWorkerPool.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) WorkerPool.Builder.putAllMetadata(Map<String, String> values) Metadata to set on the Google Compute Engine VMs.WorkerPool.Builder.putMetadata(String key, String value) Metadata to set on the Google Compute Engine VMs.WorkerPool.Builder.removeDataDisks(int index) Data disks that are used by a VM in this workflow.WorkerPool.Builder.removeMetadata(String key) Metadata to set on the Google Compute Engine VMs.WorkerPool.Builder.removePackages(int index) Packages to be installed on workers.WorkerPool.Builder.removeSdkHarnessContainerImages(int index) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.setAutoscalingSettings(AutoscalingSettings value) Settings for autoscaling of this WorkerPool.WorkerPool.Builder.setAutoscalingSettings(AutoscalingSettings.Builder builderForValue) Settings for autoscaling of this WorkerPool.WorkerPool.Builder.setDataDisks(int index, Disk value) Data disks that are used by a VM in this workflow.WorkerPool.Builder.setDataDisks(int index, Disk.Builder builderForValue) Data disks that are used by a VM in this workflow.WorkerPool.Builder.setDefaultPackageSet(DefaultPackageSet value) The default package set to install.WorkerPool.Builder.setDefaultPackageSetValue(int value) The default package set to install.WorkerPool.Builder.setDiskProvisionedIops(long value) Optional.WorkerPool.Builder.setDiskProvisionedThroughputMibps(long value) Optional.WorkerPool.Builder.setDiskSizeGb(int value) Size of root disk for VMs, in GB.WorkerPool.Builder.setDiskSourceImage(String value) Fully qualified source image for disks.WorkerPool.Builder.setDiskSourceImageBytes(com.google.protobuf.ByteString value) Fully qualified source image for disks.WorkerPool.Builder.setDiskType(String value) Type of root disk for VMs.WorkerPool.Builder.setDiskTypeBytes(com.google.protobuf.ByteString value) Type of root disk for VMs.WorkerPool.Builder.setIpConfiguration(WorkerIPAddressConfiguration value) Configuration for VM IPs.WorkerPool.Builder.setIpConfigurationValue(int value) Configuration for VM IPs.The kind of the worker pool; currently only `harness` and `shuffle` are supported.WorkerPool.Builder.setKindBytes(com.google.protobuf.ByteString value) The kind of the worker pool; currently only `harness` and `shuffle` are supported.WorkerPool.Builder.setMachineType(String value) Machine type (e.g.WorkerPool.Builder.setMachineTypeBytes(com.google.protobuf.ByteString value) Machine type (e.g.WorkerPool.Builder.setNetwork(String value) Network to which VMs will be assigned.WorkerPool.Builder.setNetworkBytes(com.google.protobuf.ByteString value) Network to which VMs will be assigned.WorkerPool.Builder.setNumThreadsPerWorker(int value) The number of threads per worker harness.WorkerPool.Builder.setNumWorkers(int value) Number of Google Compute Engine workers in this pool needed to execute the job.WorkerPool.Builder.setOnHostMaintenance(String value) The action to take on host maintenance, as defined by the Google Compute Engine API.WorkerPool.Builder.setOnHostMaintenanceBytes(com.google.protobuf.ByteString value) The action to take on host maintenance, as defined by the Google Compute Engine API.WorkerPool.Builder.setPackages(int index, Package value) Packages to be installed on workers.WorkerPool.Builder.setPackages(int index, Package.Builder builderForValue) Packages to be installed on workers.WorkerPool.Builder.setPoolArgs(com.google.protobuf.Any value) Extra arguments for this worker pool.WorkerPool.Builder.setPoolArgs(com.google.protobuf.Any.Builder builderForValue) Extra arguments for this worker pool.WorkerPool.Builder.setSdkHarnessContainerImages(int index, SdkHarnessContainerImage value) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.setSdkHarnessContainerImages(int index, SdkHarnessContainerImage.Builder builderForValue) Set of SDK harness containers needed to execute this pipeline.WorkerPool.Builder.setSubnetwork(String value) Subnetwork to which VMs will be assigned, if desired.WorkerPool.Builder.setSubnetworkBytes(com.google.protobuf.ByteString value) Subnetwork to which VMs will be assigned, if desired.WorkerPool.Builder.setTaskrunnerSettings(TaskRunnerSettings value) Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.WorkerPool.Builder.setTaskrunnerSettings(TaskRunnerSettings.Builder builderForValue) Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.WorkerPool.Builder.setTeardownPolicy(TeardownPolicy value) Sets the policy for determining when to turndown worker pool.WorkerPool.Builder.setTeardownPolicyValue(int value) Sets the policy for determining when to turndown worker pool.WorkerPool.Builder.setWorkerHarnessContainerImage(String value) Required.WorkerPool.Builder.setWorkerHarnessContainerImageBytes(com.google.protobuf.ByteString value) Required.Zone to run the worker pools in.WorkerPool.Builder.setZoneBytes(com.google.protobuf.ByteString value) Zone to run the worker pools in.WorkerPool.toBuilder()Methods in com.google.dataflow.v1beta3 that return types with arguments of type WorkerPool.BuilderModifier and TypeMethodDescriptionEnvironment.Builder.getWorkerPoolsBuilderList()The worker pools.Methods in com.google.dataflow.v1beta3 with parameters of type WorkerPool.BuilderModifier and TypeMethodDescriptionEnvironment.Builder.addWorkerPools(int index, WorkerPool.Builder builderForValue) The worker pools.Environment.Builder.addWorkerPools(WorkerPool.Builder builderForValue) The worker pools.Environment.Builder.setWorkerPools(int index, WorkerPool.Builder builderForValue) The worker pools.