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 setter, inherited

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 setter, inherited

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