Environment class

Describes the environment in which a Dataflow Job runs.

Constructors

Environment({String? clusterManagerApiService, String? dataset, DebugOptions? debugOptions, List<String>? experiments, String? flexResourceSchedulingGoal, Map<String, Object?>? internalExperiments, Map<String, Object?>? sdkPipelineOptions, String? serviceAccountEmail, String? serviceKmsKeyName, List<String>? serviceOptions, String? shuffleMode, String? tempStoragePrefix, bool? useStreamingEngineResourceBasedBilling, Map<String, Object?>? userAgent, Map<String, Object?>? version, List<WorkerPool>? workerPools, String? workerRegion, String? workerZone})

Environment.fromJson(Map json_)

Properties

clusterManagerApiService ↔ String?

The type of cluster manager API to use.

getter/setter pair

dataset ↔ String?

The dataset for the current project where various workflow related tables are stored.

getter/setter pair

debugOptions ↔ DebugOptions?

Any debugging options to be supplied to the job.

getter/setter pair

experiments ↔ List<String>?

The list of experiments to enable.

getter/setter pair

flexResourceSchedulingGoal ↔ String?

Which Flexible Resource Scheduling mode to run in. Possible string values are:

getter/setter pair

hashCode → int

The hash code for this object.

no setter, inherited

internalExperiments ↔ Map<String, Object?>?

Experimental settings.

getter/setter pair

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

sdkPipelineOptions ↔ Map<String, Object?>?

The Cloud Dataflow SDK pipeline options specified by the user.

getter/setter pair

serviceAccountEmail ↔ String?

Identity to run virtual machines as.

getter/setter pair

serviceKmsKeyName ↔ String?

If set, contains the Cloud KMS key identifier used to encrypt data at rest, AKA a Customer Managed Encryption Key (CMEK).

getter/setter pair

serviceOptions ↔ List<String>?

The list of service options to enable.

getter/setter pair

shuffleMode ↔ String?

The shuffle mode used for the job.

getter/setter pair

tempStoragePrefix ↔ String?

The prefix of the resources the system should use for temporary storage.

getter/setter pair

userAgent ↔ Map<String, Object?>?

A description of the process that generated the request.

getter/setter pair

useStreamingEngineResourceBasedBilling ↔ bool?

Whether the job uses the new streaming engine billing model based on resource usage.

getter/setter pair

version ↔ Map<String, Object?>?

A structure describing which components and their versions of the service are required in order to run the job.

getter/setter pair

workerPools ↔ List<WorkerPool>?

The worker pools.

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

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