public sealed class TaskRunnerSettings : IMessage<TaskRunnerSettings>, IEquatable<TaskRunnerSettings>, IDeepCloneable<TaskRunnerSettings>, IBufferMessage, IMessage
Reference documentation and code samples for the Dataflow v1beta3 API class TaskRunnerSettings.
Taskrunner configuration settings.
Implements
IMessageTaskRunnerSettings, IEquatableTaskRunnerSettings, IDeepCloneableTaskRunnerSettings, IBufferMessage, IMessageNamespace
Google.Cloud.Dataflow.V1Beta3Assembly
Google.Cloud.Dataflow.V1Beta3.dll
Constructors
TaskRunnerSettings()
public TaskRunnerSettings()
TaskRunnerSettings(TaskRunnerSettings)
public TaskRunnerSettings(TaskRunnerSettings other)
Parameter | |
---|---|
Name | Description |
other | TaskRunnerSettings |
Properties
Alsologtostderr
public bool Alsologtostderr { get; set; }
Whether to also send taskrunner log info to stderr.
Property Value | |
---|---|
Type | Description |
bool |
BaseTaskDir
public string BaseTaskDir { get; set; }
The location on the worker for task-specific subdirectories.
Property Value | |
---|---|
Type | Description |
string |
BaseUrl
public string BaseUrl { get; set; }
The base URL for the taskrunner to use when 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/"
Property Value | |
---|---|
Type | Description |
string |
CommandlinesFileName
public string CommandlinesFileName { get; set; }
The file to store preprocessing commands in.
Property Value | |
---|---|
Type | Description |
string |
ContinueOnException
public bool ContinueOnException { get; set; }
Whether to continue taskrunner if an exception is hit.
Property Value | |
---|---|
Type | Description |
bool |
DataflowApiVersion
public string DataflowApiVersion { get; set; }
The API version of endpoint, e.g. "v1b3"
Property Value | |
---|---|
Type | Description |
string |
HarnessCommand
public string HarnessCommand { get; set; }
The command to launch the worker harness.
Property Value | |
---|---|
Type | Description |
string |
LanguageHint
public string LanguageHint { get; set; }
The suggested backend language.
Property Value | |
---|---|
Type | Description |
string |
LogDir
public string LogDir { get; set; }
The directory on the VM to store logs.
Property Value | |
---|---|
Type | Description |
string |
LogToSerialconsole
public bool LogToSerialconsole { get; set; }
Whether to send taskrunner log info to Google Compute Engine VM serial console.
Property Value | |
---|---|
Type | Description |
bool |
LogUploadLocation
public string LogUploadLocation { get; set; }
Indicates where to put logs. If this is not specified, the logs will not be uploaded.
The supported resource type is:
Google Cloud Storage: storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}
Property Value | |
---|---|
Type | Description |
string |
OauthScopes
public RepeatedField<string> OauthScopes { get; }
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
Property Value | |
---|---|
Type | Description |
RepeatedFieldstring |
ParallelWorkerSettings
public WorkerSettings ParallelWorkerSettings { get; set; }
The settings to pass to the parallel worker harness.
Property Value | |
---|---|
Type | Description |
WorkerSettings |
StreamingWorkerMainClass
public string StreamingWorkerMainClass { get; set; }
The streaming worker main class name.
Property Value | |
---|---|
Type | Description |
string |
TaskGroup
public string TaskGroup { get; set; }
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
Property Value | |
---|---|
Type | Description |
string |
TaskUser
public string TaskUser { get; set; }
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
Property Value | |
---|---|
Type | Description |
string |
TempStoragePrefix
public string TempStoragePrefix { get; set; }
The prefix of the resources the taskrunner should use for temporary storage.
The supported resource type is:
Google Cloud Storage: storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}
Property Value | |
---|---|
Type | Description |
string |
VmId
public string VmId { get; set; }
The ID string of the VM.
Property Value | |
---|---|
Type | Description |
string |
WorkflowFileName
public string WorkflowFileName { get; set; }
The file to store the workflow in.
Property Value | |
---|---|
Type | Description |
string |