WorkerPool class

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.

Constructors

WorkerPool({AutoscalingSettings? autoscalingSettings, List<Disk>? dataDisks, String? defaultPackageSet, int? diskSizeGb, String? diskSourceImage, String? diskType, String? ipConfiguration, String? kind, String? machineType, Map<String, String>? metadata, String? network, int? numThreadsPerWorker, int? numWorkers, String? onHostMaintenance, List<Package>? packages, Map<String, Object?>? poolArgs, List<SdkHarnessContainerImage>? sdkHarnessContainerImages, String? subnetwork, TaskRunnerSettings? taskrunnerSettings, String? teardownPolicy, String? workerHarnessContainerImage, String? zone})
WorkerPool.fromJson(Map json_)

Properties

autoscalingSettings AutoscalingSettings?
Settings for autoscaling of this WorkerPool.
getter/setter pair
dataDisks List<Disk>?
Data disks that are used by a VM in this workflow.
getter/setter pair
defaultPackageSet String?
The default package set to install.
getter/setter pair
diskSizeGb int?
Size of root disk for VMs, in GB.
getter/setter pair
diskSourceImage String?
Fully qualified source image for disks.
getter/setter pair
diskType String?
Type of root disk for VMs.
getter/setter pair
hashCode int
The hash code for this object.
no setterinherited
ipConfiguration String?
Configuration for VM IPs. Possible string values are:
getter/setter pair
kind String?
The kind of the worker pool; currently only harness and shuffle are supported.
getter/setter pair
machineType String?
Machine type (e.g. "n1-standard-1").
getter/setter pair
metadata Map<String, String>?
Metadata to set on the Google Compute Engine VMs.
getter/setter pair
network String?
Network to which VMs will be assigned.
getter/setter pair
numThreadsPerWorker int?
The number of threads per worker harness.
getter/setter pair
numWorkers int?
Number of Google Compute Engine workers in this pool needed to execute the job.
getter/setter pair
onHostMaintenance String?
The action to take on host maintenance, as defined by the Google Compute Engine API.
getter/setter pair
packages List<Package>?
Packages to be installed on workers.
getter/setter pair
poolArgs Map<String, Object?>?
Extra arguments for this worker pool.
getter/setter pair
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
sdkHarnessContainerImages List<SdkHarnessContainerImage>?
Set of SDK harness containers needed to execute this pipeline.
getter/setter pair
subnetwork String?
Subnetwork to which VMs will be assigned, if desired.
getter/setter pair
taskrunnerSettings TaskRunnerSettings?
Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.
getter/setter pair
teardownPolicy String?
Sets the policy for determining when to turndown worker pool.
getter/setter pair
workerHarnessContainerImage String?
Docker container image that executes the Cloud Dataflow worker harness, residing in Google Container Registry.
getter/setter pair
zone String?
Zone to run the worker pools in.
getter/setter pair

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toJson() Map<String, dynamic>
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited