WorkerSettings class
Provides data to pass through to the worker harness.
Constructors
-
WorkerSettings({Input<
String> ? baseUrl, Input<bool> ? reportingEnabled, Input<String> ? servicePath, Input<String> ? shuffleServicePath, Input<String> ? tempStoragePrefix, Input<String> ? workerId}) -
Creates a new WorkerSettings.
baseUrlThe base URL for accessing Google Cloud APIs. When workers access Google Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, "Relative Uniform Resource Locators". If not specified, the default value is "http://www.googleapis.com/"reportingEnabledWhether to send work progress updates to the service.servicePathThe Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".shuffleServicePathThe Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".tempStoragePrefixThe prefix of the resources the system should use for temporary storage. The supported resource type is: Google Cloud Storage: storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}workerIdThe ID of the worker running this pipeline.const -
WorkerSettings.fromMap(Map<
String, dynamic> map) -
factory
Properties
-
baseUrl
→ Input<
String> ? -
The base URL for accessing Google Cloud APIs. When workers access Google Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, "Relative Uniform Resource Locators". If not specified, the default value is "http://www.googleapis.com/"
final
- hashCode → int
-
The hash code for this object.
no setterinherited
-
reportingEnabled
→ Input<
bool> ? -
Whether to send work progress updates to the service.
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
-
servicePath
→ Input<
String> ? -
The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".
final
-
shuffleServicePath
→ Input<
String> ? -
The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".
final
-
tempStoragePrefix
→ Input<
String> ? -
The prefix of the resources the system should use for temporary storage. The supported resource type is: Google Cloud Storage: storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}
final
-
workerId
→ Input<
String> ? -
The ID of the worker running this pipeline.
final
Methods
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toMap(
) → Map< String, dynamic> -
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited