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
harnessandshuffleare 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