Reference documentation and code samples for the Google Cloud Dataflow V1beta3 Client class TaskRunnerSettings.
Taskrunner configuration settings.
Generated from protobuf message google.dataflow.v1beta3.TaskRunnerSettings
Methods
__construct
Constructor.
data
array
Optional. Data for populating the Message object.
↳ task_user
string
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
↳ task_group
string
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
↳ oauth_scopes
array
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
↳ base_url
string
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/ "
↳ dataflow_api_version
string
The API version of endpoint, e.g. "v1b3"
↳ parallel_worker_settings
↳ base_task_dir
string
The location on the worker for task-specific subdirectories.
↳ continue_on_exception
bool
Whether to continue taskrunner if an exception is hit.
↳ log_to_serialconsole
bool
Whether to send taskrunner log info to Google Compute Engine VM serial console.
↳ alsologtostderr
bool
Whether to also send taskrunner log info to stderr.
↳ log_upload_location
string
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}
↳ log_dir
string
The directory on the VM to store logs.
↳ temp_storage_prefix
string
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}
↳ harness_command
string
The command to launch the worker harness.
↳ workflow_file_name
string
The file to store the workflow in.
↳ commandlines_file_name
string
The file to store preprocessing commands in.
↳ vm_id
string
The ID string of the VM.
↳ language_hint
string
The suggested backend language.
↳ streaming_worker_main_class
string
The streaming worker main class name.
getTaskUser
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string
setTaskUser
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
var
string
$this
getTaskGroup
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string
setTaskGroup
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
var
string
$this
getOauthScopes
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
setOauthScopes
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
var
string[]
$this
getBaseUrl
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/ "
string
setBaseUrl
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/ "
var
string
$this
getDataflowApiVersion
The API version of endpoint, e.g. "v1b3"
string
setDataflowApiVersion
The API version of endpoint, e.g. "v1b3"
var
string
$this
getParallelWorkerSettings
The settings to pass to the parallel worker harness.
hasParallelWorkerSettings
clearParallelWorkerSettings
setParallelWorkerSettings
The settings to pass to the parallel worker harness.
$this
getBaseTaskDir
The location on the worker for task-specific subdirectories.
string
setBaseTaskDir
The location on the worker for task-specific subdirectories.
var
string
$this
getContinueOnException
Whether to continue taskrunner if an exception is hit.
bool
setContinueOnException
Whether to continue taskrunner if an exception is hit.
var
bool
$this
getLogToSerialconsole
Whether to send taskrunner log info to Google Compute Engine VM serial console.
bool
setLogToSerialconsole
Whether to send taskrunner log info to Google Compute Engine VM serial console.
var
bool
$this
getAlsologtostderr
Whether to also send taskrunner log info to stderr.
bool
setAlsologtostderr
Whether to also send taskrunner log info to stderr.
var
bool
$this
getLogUploadLocation
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}
string
setLogUploadLocation
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}
var
string
$this
getLogDir
The directory on the VM to store logs.
string
setLogDir
The directory on the VM to store logs.
var
string
$this
getTempStoragePrefix
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}
string
setTempStoragePrefix
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}
var
string
$this
getHarnessCommand
The command to launch the worker harness.
string
setHarnessCommand
The command to launch the worker harness.
var
string
$this
getWorkflowFileName
The file to store the workflow in.
string
setWorkflowFileName
The file to store the workflow in.
var
string
$this
getCommandlinesFileName
The file to store preprocessing commands in.
string
setCommandlinesFileName
The file to store preprocessing commands in.
var
string
$this
getVmId
The ID string of the VM.
string
setVmId
The ID string of the VM.
var
string
$this
getLanguageHint
The suggested backend language.
string
setLanguageHint
The suggested backend language.
var
string
$this
getStreamingWorkerMainClass
The streaming worker main class name.
string
setStreamingWorkerMainClass
The streaming worker main class name.
var
string
$this
