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? enableLauncherVmSerialPortLogging, 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, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process.
getter/setter pair
enableLauncherVmSerialPortLogging ↔ bool?
If true serial port logging will be enabled for the launcher VM.
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 setterinherited
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 setterinherited
saveHeapDumpsToGcsPath ↔ String?
Cloud Storage bucket (directory) to upload heap dumps to.
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