- 0.56.0 (latest)
- 0.55.0
- 0.53.0
- 0.52.0
- 0.51.0
- 0.50.0
- 0.49.0
- 0.48.0
- 0.47.0
- 0.46.0
- 0.45.0
- 0.44.0
- 0.43.0
- 0.41.0
- 0.40.0
- 0.39.0
- 0.38.0
- 0.37.0
- 0.36.0
- 0.35.0
- 0.34.0
- 0.33.0
- 0.32.0
- 0.31.0
- 0.28.0
- 0.27.0
- 0.26.0
- 0.25.0
- 0.24.0
- 0.23.0
- 0.22.0
- 0.21.0
- 0.20.0
- 0.19.0
- 0.18.0
- 0.17.0
- 0.16.0
- 0.15.0
- 0.13.0
- 0.12.0
- 0.11.0
- 0.10.0
- 0.9.0
- 0.8.0
- 0.5.0
public static final class TaskRunnerSettings.Builder extends GeneratedMessageV3.Builder<TaskRunnerSettings.Builder> implements TaskRunnerSettingsOrBuilderTaskrunner configuration settings.
Protobuf type google.dataflow.v1beta3.TaskRunnerSettings
Inheritance
Object > AbstractMessageLite.Builder<MessageType,BuilderType> > AbstractMessage.Builder<BuilderType> > GeneratedMessageV3.Builder > TaskRunnerSettings.BuilderImplements
TaskRunnerSettingsOrBuilderStatic Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()| Returns | |
|---|---|
| Type | Description |
Descriptor |
|
Methods
addAllOauthScopes(Iterable<String> values)
public TaskRunnerSettings.Builder addAllOauthScopes(Iterable<String> values)The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Parameter | |
|---|---|
| Name | Description |
values |
Iterable<String>The oauthScopes to add. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
addOauthScopes(String value)
public TaskRunnerSettings.Builder addOauthScopes(String value)The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe oauthScopes to add. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
addOauthScopesBytes(ByteString value)
public TaskRunnerSettings.Builder addOauthScopesBytes(ByteString value)The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes of the oauthScopes to add. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public TaskRunnerSettings.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)| Parameters | |
|---|---|
| Name | Description |
field |
FieldDescriptor |
value |
Object |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
build()
public TaskRunnerSettings build()| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings |
|
buildPartial()
public TaskRunnerSettings buildPartial()| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings |
|
clear()
public TaskRunnerSettings.Builder clear()| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
clearAlsologtostderr()
public TaskRunnerSettings.Builder clearAlsologtostderr()Whether to also send taskrunner log info to stderr.
bool alsologtostderr = 10;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearBaseTaskDir()
public TaskRunnerSettings.Builder clearBaseTaskDir()The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearBaseUrl()
public TaskRunnerSettings.Builder clearBaseUrl()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 base_url = 4;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearCommandlinesFileName()
public TaskRunnerSettings.Builder clearCommandlinesFileName()The file to store preprocessing commands in.
string commandlines_file_name = 16;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearContinueOnException()
public TaskRunnerSettings.Builder clearContinueOnException()Whether to continue taskrunner if an exception is hit.
bool continue_on_exception = 8;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearDataflowApiVersion()
public TaskRunnerSettings.Builder clearDataflowApiVersion()The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearField(Descriptors.FieldDescriptor field)
public TaskRunnerSettings.Builder clearField(Descriptors.FieldDescriptor field)| Parameter | |
|---|---|
| Name | Description |
field |
FieldDescriptor |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
clearHarnessCommand()
public TaskRunnerSettings.Builder clearHarnessCommand()The command to launch the worker harness.
string harness_command = 14;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearLanguageHint()
public TaskRunnerSettings.Builder clearLanguageHint()The suggested backend language.
string language_hint = 18;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearLogDir()
public TaskRunnerSettings.Builder clearLogDir()The directory on the VM to store logs.
string log_dir = 12;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearLogToSerialconsole()
public TaskRunnerSettings.Builder clearLogToSerialconsole()Whether to send taskrunner log info to Google Compute Engine VM serial console.
bool log_to_serialconsole = 9;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearLogUploadLocation()
public TaskRunnerSettings.Builder clearLogUploadLocation()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 log_upload_location = 11;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearOauthScopes()
public TaskRunnerSettings.Builder clearOauthScopes()The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearOneof(Descriptors.OneofDescriptor oneof)
public TaskRunnerSettings.Builder clearOneof(Descriptors.OneofDescriptor oneof)| Parameter | |
|---|---|
| Name | Description |
oneof |
OneofDescriptor |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
clearParallelWorkerSettings()
public TaskRunnerSettings.Builder clearParallelWorkerSettings()The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
clearStreamingWorkerMainClass()
public TaskRunnerSettings.Builder clearStreamingWorkerMainClass()The streaming worker main class name.
string streaming_worker_main_class = 19;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearTaskGroup()
public TaskRunnerSettings.Builder clearTaskGroup()The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearTaskUser()
public TaskRunnerSettings.Builder clearTaskUser()The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearTempStoragePrefix()
public TaskRunnerSettings.Builder clearTempStoragePrefix()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 temp_storage_prefix = 13;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearVmId()
public TaskRunnerSettings.Builder clearVmId()The ID string of the VM.
string vm_id = 17;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clearWorkflowFileName()
public TaskRunnerSettings.Builder clearWorkflowFileName()The file to store the workflow in.
string workflow_file_name = 15;
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
clone()
public TaskRunnerSettings.Builder clone()| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
getAlsologtostderr()
public boolean getAlsologtostderr()Whether to also send taskrunner log info to stderr.
bool alsologtostderr = 10;
| Returns | |
|---|---|
| Type | Description |
boolean |
The alsologtostderr. |
getBaseTaskDir()
public String getBaseTaskDir()The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
| Returns | |
|---|---|
| Type | Description |
String |
The baseTaskDir. |
getBaseTaskDirBytes()
public ByteString getBaseTaskDirBytes()The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for baseTaskDir. |
getBaseUrl()
public String 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 base_url = 4;
| Returns | |
|---|---|
| Type | Description |
String |
The baseUrl. |
getBaseUrlBytes()
public ByteString getBaseUrlBytes()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 base_url = 4;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for baseUrl. |
getCommandlinesFileName()
public String getCommandlinesFileName()The file to store preprocessing commands in.
string commandlines_file_name = 16;
| Returns | |
|---|---|
| Type | Description |
String |
The commandlinesFileName. |
getCommandlinesFileNameBytes()
public ByteString getCommandlinesFileNameBytes()The file to store preprocessing commands in.
string commandlines_file_name = 16;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for commandlinesFileName. |
getContinueOnException()
public boolean getContinueOnException()Whether to continue taskrunner if an exception is hit.
bool continue_on_exception = 8;
| Returns | |
|---|---|
| Type | Description |
boolean |
The continueOnException. |
getDataflowApiVersion()
public String getDataflowApiVersion()The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
| Returns | |
|---|---|
| Type | Description |
String |
The dataflowApiVersion. |
getDataflowApiVersionBytes()
public ByteString getDataflowApiVersionBytes()The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for dataflowApiVersion. |
getDefaultInstanceForType()
public TaskRunnerSettings getDefaultInstanceForType()| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings |
|
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()| Returns | |
|---|---|
| Type | Description |
Descriptor |
|
getHarnessCommand()
public String getHarnessCommand()The command to launch the worker harness.
string harness_command = 14;
| Returns | |
|---|---|
| Type | Description |
String |
The harnessCommand. |
getHarnessCommandBytes()
public ByteString getHarnessCommandBytes()The command to launch the worker harness.
string harness_command = 14;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for harnessCommand. |
getLanguageHint()
public String getLanguageHint()The suggested backend language.
string language_hint = 18;
| Returns | |
|---|---|
| Type | Description |
String |
The languageHint. |
getLanguageHintBytes()
public ByteString getLanguageHintBytes()The suggested backend language.
string language_hint = 18;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for languageHint. |
getLogDir()
public String getLogDir()The directory on the VM to store logs.
string log_dir = 12;
| Returns | |
|---|---|
| Type | Description |
String |
The logDir. |
getLogDirBytes()
public ByteString getLogDirBytes()The directory on the VM to store logs.
string log_dir = 12;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for logDir. |
getLogToSerialconsole()
public boolean getLogToSerialconsole()Whether to send taskrunner log info to Google Compute Engine VM serial console.
bool log_to_serialconsole = 9;
| Returns | |
|---|---|
| Type | Description |
boolean |
The logToSerialconsole. |
getLogUploadLocation()
public String 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 log_upload_location = 11;
| Returns | |
|---|---|
| Type | Description |
String |
The logUploadLocation. |
getLogUploadLocationBytes()
public ByteString getLogUploadLocationBytes()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 log_upload_location = 11;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for logUploadLocation. |
getOauthScopes(int index)
public String getOauthScopes(int index)The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Parameter | |
|---|---|
| Name | Description |
index |
intThe index of the element to return. |
| Returns | |
|---|---|
| Type | Description |
String |
The oauthScopes at the given index. |
getOauthScopesBytes(int index)
public ByteString getOauthScopesBytes(int index)The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Parameter | |
|---|---|
| Name | Description |
index |
intThe index of the value to return. |
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes of the oauthScopes at the given index. |
getOauthScopesCount()
public int getOauthScopesCount()The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Returns | |
|---|---|
| Type | Description |
int |
The count of oauthScopes. |
getOauthScopesList()
public ProtocolStringList getOauthScopesList()The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Returns | |
|---|---|
| Type | Description |
ProtocolStringList |
A list containing the oauthScopes. |
getParallelWorkerSettings()
public WorkerSettings getParallelWorkerSettings()The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Returns | |
|---|---|
| Type | Description |
WorkerSettings |
The parallelWorkerSettings. |
getParallelWorkerSettingsBuilder()
public WorkerSettings.Builder getParallelWorkerSettingsBuilder()The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Returns | |
|---|---|
| Type | Description |
WorkerSettings.Builder |
|
getParallelWorkerSettingsOrBuilder()
public WorkerSettingsOrBuilder getParallelWorkerSettingsOrBuilder()The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Returns | |
|---|---|
| Type | Description |
WorkerSettingsOrBuilder |
|
getStreamingWorkerMainClass()
public String getStreamingWorkerMainClass()The streaming worker main class name.
string streaming_worker_main_class = 19;
| Returns | |
|---|---|
| Type | Description |
String |
The streamingWorkerMainClass. |
getStreamingWorkerMainClassBytes()
public ByteString getStreamingWorkerMainClassBytes()The streaming worker main class name.
string streaming_worker_main_class = 19;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for streamingWorkerMainClass. |
getTaskGroup()
public String getTaskGroup()The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
| Returns | |
|---|---|
| Type | Description |
String |
The taskGroup. |
getTaskGroupBytes()
public ByteString getTaskGroupBytes()The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for taskGroup. |
getTaskUser()
public String getTaskUser()The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
| Returns | |
|---|---|
| Type | Description |
String |
The taskUser. |
getTaskUserBytes()
public ByteString getTaskUserBytes()The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for taskUser. |
getTempStoragePrefix()
public String 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 temp_storage_prefix = 13;
| Returns | |
|---|---|
| Type | Description |
String |
The tempStoragePrefix. |
getTempStoragePrefixBytes()
public ByteString getTempStoragePrefixBytes()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 temp_storage_prefix = 13;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for tempStoragePrefix. |
getVmId()
public String getVmId()The ID string of the VM.
string vm_id = 17;
| Returns | |
|---|---|
| Type | Description |
String |
The vmId. |
getVmIdBytes()
public ByteString getVmIdBytes()The ID string of the VM.
string vm_id = 17;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for vmId. |
getWorkflowFileName()
public String getWorkflowFileName()The file to store the workflow in.
string workflow_file_name = 15;
| Returns | |
|---|---|
| Type | Description |
String |
The workflowFileName. |
getWorkflowFileNameBytes()
public ByteString getWorkflowFileNameBytes()The file to store the workflow in.
string workflow_file_name = 15;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for workflowFileName. |
hasParallelWorkerSettings()
public boolean hasParallelWorkerSettings()The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Returns | |
|---|---|
| Type | Description |
boolean |
Whether the parallelWorkerSettings field is set. |
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()| Returns | |
|---|---|
| Type | Description |
FieldAccessorTable |
|
isInitialized()
public final boolean isInitialized()| Returns | |
|---|---|
| Type | Description |
boolean |
|
mergeFrom(TaskRunnerSettings other)
public TaskRunnerSettings.Builder mergeFrom(TaskRunnerSettings other)| Parameter | |
|---|---|
| Name | Description |
other |
TaskRunnerSettings |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public TaskRunnerSettings.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)| Parameters | |
|---|---|
| Name | Description |
input |
CodedInputStream |
extensionRegistry |
ExtensionRegistryLite |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
| Exceptions | |
|---|---|
| Type | Description |
IOException |
|
mergeFrom(Message other)
public TaskRunnerSettings.Builder mergeFrom(Message other)| Parameter | |
|---|---|
| Name | Description |
other |
Message |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
mergeParallelWorkerSettings(WorkerSettings value)
public TaskRunnerSettings.Builder mergeParallelWorkerSettings(WorkerSettings value)The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Parameter | |
|---|---|
| Name | Description |
value |
WorkerSettings |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
mergeUnknownFields(UnknownFieldSet unknownFields)
public final TaskRunnerSettings.Builder mergeUnknownFields(UnknownFieldSet unknownFields)| Parameter | |
|---|---|
| Name | Description |
unknownFields |
UnknownFieldSet |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
setAlsologtostderr(boolean value)
public TaskRunnerSettings.Builder setAlsologtostderr(boolean value)Whether to also send taskrunner log info to stderr.
bool alsologtostderr = 10;
| Parameter | |
|---|---|
| Name | Description |
value |
booleanThe alsologtostderr to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setBaseTaskDir(String value)
public TaskRunnerSettings.Builder setBaseTaskDir(String value)The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe baseTaskDir to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setBaseTaskDirBytes(ByteString value)
public TaskRunnerSettings.Builder setBaseTaskDirBytes(ByteString value)The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for baseTaskDir to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setBaseUrl(String value)
public TaskRunnerSettings.Builder setBaseUrl(String value)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 base_url = 4;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe baseUrl to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setBaseUrlBytes(ByteString value)
public TaskRunnerSettings.Builder setBaseUrlBytes(ByteString value)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 base_url = 4;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for baseUrl to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setCommandlinesFileName(String value)
public TaskRunnerSettings.Builder setCommandlinesFileName(String value)The file to store preprocessing commands in.
string commandlines_file_name = 16;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe commandlinesFileName to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setCommandlinesFileNameBytes(ByteString value)
public TaskRunnerSettings.Builder setCommandlinesFileNameBytes(ByteString value)The file to store preprocessing commands in.
string commandlines_file_name = 16;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for commandlinesFileName to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setContinueOnException(boolean value)
public TaskRunnerSettings.Builder setContinueOnException(boolean value)Whether to continue taskrunner if an exception is hit.
bool continue_on_exception = 8;
| Parameter | |
|---|---|
| Name | Description |
value |
booleanThe continueOnException to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setDataflowApiVersion(String value)
public TaskRunnerSettings.Builder setDataflowApiVersion(String value)The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe dataflowApiVersion to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setDataflowApiVersionBytes(ByteString value)
public TaskRunnerSettings.Builder setDataflowApiVersionBytes(ByteString value)The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for dataflowApiVersion to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setField(Descriptors.FieldDescriptor field, Object value)
public TaskRunnerSettings.Builder setField(Descriptors.FieldDescriptor field, Object value)| Parameters | |
|---|---|
| Name | Description |
field |
FieldDescriptor |
value |
Object |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
setHarnessCommand(String value)
public TaskRunnerSettings.Builder setHarnessCommand(String value)The command to launch the worker harness.
string harness_command = 14;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe harnessCommand to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setHarnessCommandBytes(ByteString value)
public TaskRunnerSettings.Builder setHarnessCommandBytes(ByteString value)The command to launch the worker harness.
string harness_command = 14;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for harnessCommand to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLanguageHint(String value)
public TaskRunnerSettings.Builder setLanguageHint(String value)The suggested backend language.
string language_hint = 18;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe languageHint to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLanguageHintBytes(ByteString value)
public TaskRunnerSettings.Builder setLanguageHintBytes(ByteString value)The suggested backend language.
string language_hint = 18;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for languageHint to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLogDir(String value)
public TaskRunnerSettings.Builder setLogDir(String value)The directory on the VM to store logs.
string log_dir = 12;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe logDir to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLogDirBytes(ByteString value)
public TaskRunnerSettings.Builder setLogDirBytes(ByteString value)The directory on the VM to store logs.
string log_dir = 12;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for logDir to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLogToSerialconsole(boolean value)
public TaskRunnerSettings.Builder setLogToSerialconsole(boolean value)Whether to send taskrunner log info to Google Compute Engine VM serial console.
bool log_to_serialconsole = 9;
| Parameter | |
|---|---|
| Name | Description |
value |
booleanThe logToSerialconsole to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLogUploadLocation(String value)
public TaskRunnerSettings.Builder setLogUploadLocation(String value)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 log_upload_location = 11;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe logUploadLocation to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setLogUploadLocationBytes(ByteString value)
public TaskRunnerSettings.Builder setLogUploadLocationBytes(ByteString value)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 log_upload_location = 11;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for logUploadLocation to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setOauthScopes(int index, String value)
public TaskRunnerSettings.Builder setOauthScopes(int index, String value)The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
| Parameters | |
|---|---|
| Name | Description |
index |
intThe index to set the value at. |
value |
StringThe oauthScopes to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setParallelWorkerSettings(WorkerSettings value)
public TaskRunnerSettings.Builder setParallelWorkerSettings(WorkerSettings value)The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Parameter | |
|---|---|
| Name | Description |
value |
WorkerSettings |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
setParallelWorkerSettings(WorkerSettings.Builder builderForValue)
public TaskRunnerSettings.Builder setParallelWorkerSettings(WorkerSettings.Builder builderForValue)The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
| Parameter | |
|---|---|
| Name | Description |
builderForValue |
WorkerSettings.Builder |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public TaskRunnerSettings.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)| Parameters | |
|---|---|
| Name | Description |
field |
FieldDescriptor |
index |
int |
value |
Object |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
setStreamingWorkerMainClass(String value)
public TaskRunnerSettings.Builder setStreamingWorkerMainClass(String value)The streaming worker main class name.
string streaming_worker_main_class = 19;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe streamingWorkerMainClass to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setStreamingWorkerMainClassBytes(ByteString value)
public TaskRunnerSettings.Builder setStreamingWorkerMainClassBytes(ByteString value)The streaming worker main class name.
string streaming_worker_main_class = 19;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for streamingWorkerMainClass to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setTaskGroup(String value)
public TaskRunnerSettings.Builder setTaskGroup(String value)The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe taskGroup to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setTaskGroupBytes(ByteString value)
public TaskRunnerSettings.Builder setTaskGroupBytes(ByteString value)The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for taskGroup to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setTaskUser(String value)
public TaskRunnerSettings.Builder setTaskUser(String value)The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe taskUser to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setTaskUserBytes(ByteString value)
public TaskRunnerSettings.Builder setTaskUserBytes(ByteString value)The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for taskUser to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setTempStoragePrefix(String value)
public TaskRunnerSettings.Builder setTempStoragePrefix(String value)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 temp_storage_prefix = 13;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe tempStoragePrefix to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setTempStoragePrefixBytes(ByteString value)
public TaskRunnerSettings.Builder setTempStoragePrefixBytes(ByteString value)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 temp_storage_prefix = 13;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for tempStoragePrefix to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setUnknownFields(UnknownFieldSet unknownFields)
public final TaskRunnerSettings.Builder setUnknownFields(UnknownFieldSet unknownFields)| Parameter | |
|---|---|
| Name | Description |
unknownFields |
UnknownFieldSet |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
|
setVmId(String value)
public TaskRunnerSettings.Builder setVmId(String value)The ID string of the VM.
string vm_id = 17;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe vmId to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setVmIdBytes(ByteString value)
public TaskRunnerSettings.Builder setVmIdBytes(ByteString value)The ID string of the VM.
string vm_id = 17;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for vmId to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setWorkflowFileName(String value)
public TaskRunnerSettings.Builder setWorkflowFileName(String value)The file to store the workflow in.
string workflow_file_name = 15;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe workflowFileName to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |
setWorkflowFileNameBytes(ByteString value)
public TaskRunnerSettings.Builder setWorkflowFileNameBytes(ByteString value)The file to store the workflow in.
string workflow_file_name = 15;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for workflowFileName to set. |
| Returns | |
|---|---|
| Type | Description |
TaskRunnerSettings.Builder |
This builder for chaining. |