FlexTemplateRuntimeEnvironment class

The environment values to be set at runtime for flex template.

Constructors

FlexTemplateRuntimeEnvironment({List<String>? additionalExperiments, Map<String, String>? additionalUserLabels, String? autoscalingAlgorithm, int? diskSizeGb, bool? dumpHeapOnOom, bool? enableStreamingEngine, String? flexrsGoal, String? ipConfiguration, String? kmsKeyName, String? launcherMachineType, String? machineType, int? maxWorkers, String? network, int? numWorkers, String? saveHeapDumpsToGcsPath, String? sdkContainerImage, String? serviceAccountEmail, String? stagingLocation, String? subnetwork, String? tempLocation, String? workerRegion, String? workerZone, String? zone})

FlexTemplateRuntimeEnvironment.fromJson(Map _json)

Properties

additionalExperiments ↔ List<String>?

Additional experiment flags for the job.

getter/setter pair

additionalUserLabels ↔ Map<String, String>?

Additional user labels to be specified for the job.

getter/setter pair

autoscalingAlgorithm ↔ String?

The algorithm to use for autoscaling Possible string values are:

getter/setter pair

diskSizeGb ↔ int?

Worker disk size, in gigabytes.

getter/setter pair

dumpHeapOnOom ↔ bool?

If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory.

getter/setter pair

enableStreamingEngine ↔ bool?

Whether to enable Streaming Engine for the job.

getter/setter pair

flexrsGoal ↔ String?

Set FlexRS goal for the job.

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

kmsKeyName ↔ String?

Name for the Cloud KMS key for the job.

getter/setter pair

launcherMachineType ↔ String?

The machine type to use for launching the job.

getter/setter pair

machineType ↔ String?

The machine type to use for the job.

getter/setter pair

maxWorkers ↔ int?

The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.

getter/setter pair

network ↔ String?

Network to which VMs will be assigned.

getter/setter pair

numWorkers ↔ int?

The initial number of Google Compute Engine instances for the job.

getter/setter pair

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

saveHeapDumpsToGcsPath ↔ String?

Cloud Storage bucket (directory) to upload heap dumps to the given location.

getter/setter pair

sdkContainerImage ↔ String?

Docker registry location of container image to use for the 'worker harness.

getter/setter pair

serviceAccountEmail ↔ String?

The email address of the service account to run the job as.

getter/setter pair

stagingLocation ↔ String?

The Cloud Storage path for staging local files.

getter/setter pair

subnetwork ↔ String?

Subnetwork to which VMs will be assigned, if desired.

getter/setter pair

tempLocation ↔ String?

The Cloud Storage path to use for temporary files.

getter/setter pair

workerRegion ↔ String?

The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1".

getter/setter pair

workerZone ↔ String?

The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1-a".

getter/setter pair

zone ↔ String?

The Compute Engine availability zone for launching worker instances to run your pipeline.

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