Package com.google.dataflow.v1beta3
Class TaskRunnerSettings.Builder
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite.Builder
-
- com.google.protobuf.AbstractMessage.Builder<BuilderT>
-
- com.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
- com.google.dataflow.v1beta3.TaskRunnerSettings.Builder
-
- All Implemented Interfaces:
TaskRunnerSettingsOrBuilder
,com.google.protobuf.Message.Builder
,com.google.protobuf.MessageLite.Builder
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Cloneable
- Enclosing class:
- TaskRunnerSettings
public static final class TaskRunnerSettings.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder> implements TaskRunnerSettingsOrBuilder
Taskrunner configuration settings.
Protobuf typegoogle.dataflow.v1beta3.TaskRunnerSettings
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description TaskRunnerSettings.Builder
addAllOauthScopes(Iterable<String> values)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.TaskRunnerSettings.Builder
addOauthScopes(String value)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.TaskRunnerSettings.Builder
addOauthScopesBytes(com.google.protobuf.ByteString value)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.TaskRunnerSettings.Builder
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
TaskRunnerSettings
build()
TaskRunnerSettings
buildPartial()
TaskRunnerSettings.Builder
clear()
TaskRunnerSettings.Builder
clearAlsologtostderr()
Whether to also send taskrunner log info to stderr.TaskRunnerSettings.Builder
clearBaseTaskDir()
The location on the worker for task-specific subdirectories.TaskRunnerSettings.Builder
clearBaseUrl()
The base URL for the taskrunner to use when accessing Google Cloud APIs.TaskRunnerSettings.Builder
clearCommandlinesFileName()
The file to store preprocessing commands in.TaskRunnerSettings.Builder
clearContinueOnException()
Whether to continue taskrunner if an exception is hit.TaskRunnerSettings.Builder
clearDataflowApiVersion()
The API version of endpoint, e.g.TaskRunnerSettings.Builder
clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
TaskRunnerSettings.Builder
clearHarnessCommand()
The command to launch the worker harness.TaskRunnerSettings.Builder
clearLanguageHint()
The suggested backend language.TaskRunnerSettings.Builder
clearLogDir()
The directory on the VM to store logs.TaskRunnerSettings.Builder
clearLogToSerialconsole()
Whether to send taskrunner log info to Google Compute Engine VM serial console.TaskRunnerSettings.Builder
clearLogUploadLocation()
Indicates where to put logs.TaskRunnerSettings.Builder
clearOauthScopes()
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.TaskRunnerSettings.Builder
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
TaskRunnerSettings.Builder
clearParallelWorkerSettings()
The settings to pass to the parallel worker harness.TaskRunnerSettings.Builder
clearStreamingWorkerMainClass()
The streaming worker main class name.TaskRunnerSettings.Builder
clearTaskGroup()
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g.TaskRunnerSettings.Builder
clearTaskUser()
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g.TaskRunnerSettings.Builder
clearTempStoragePrefix()
The prefix of the resources the taskrunner should use for temporary storage.TaskRunnerSettings.Builder
clearVmId()
The ID string of the VM.TaskRunnerSettings.Builder
clearWorkflowFileName()
The file to store the workflow in.TaskRunnerSettings.Builder
clone()
boolean
getAlsologtostderr()
Whether to also send taskrunner log info to stderr.String
getBaseTaskDir()
The location on the worker for task-specific subdirectories.com.google.protobuf.ByteString
getBaseTaskDirBytes()
The location on the worker for task-specific subdirectories.String
getBaseUrl()
The base URL for the taskrunner to use when accessing Google Cloud APIs.com.google.protobuf.ByteString
getBaseUrlBytes()
The base URL for the taskrunner to use when accessing Google Cloud APIs.String
getCommandlinesFileName()
The file to store preprocessing commands in.com.google.protobuf.ByteString
getCommandlinesFileNameBytes()
The file to store preprocessing commands in.boolean
getContinueOnException()
Whether to continue taskrunner if an exception is hit.String
getDataflowApiVersion()
The API version of endpoint, e.g.com.google.protobuf.ByteString
getDataflowApiVersionBytes()
The API version of endpoint, e.g.TaskRunnerSettings
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
com.google.protobuf.Descriptors.Descriptor
getDescriptorForType()
String
getHarnessCommand()
The command to launch the worker harness.com.google.protobuf.ByteString
getHarnessCommandBytes()
The command to launch the worker harness.String
getLanguageHint()
The suggested backend language.com.google.protobuf.ByteString
getLanguageHintBytes()
The suggested backend language.String
getLogDir()
The directory on the VM to store logs.com.google.protobuf.ByteString
getLogDirBytes()
The directory on the VM to store logs.boolean
getLogToSerialconsole()
Whether to send taskrunner log info to Google Compute Engine VM serial console.String
getLogUploadLocation()
Indicates where to put logs.com.google.protobuf.ByteString
getLogUploadLocationBytes()
Indicates where to put logs.String
getOauthScopes(int index)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.com.google.protobuf.ByteString
getOauthScopesBytes(int index)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.int
getOauthScopesCount()
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.com.google.protobuf.ProtocolStringList
getOauthScopesList()
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.WorkerSettings
getParallelWorkerSettings()
The settings to pass to the parallel worker harness.WorkerSettings.Builder
getParallelWorkerSettingsBuilder()
The settings to pass to the parallel worker harness.WorkerSettingsOrBuilder
getParallelWorkerSettingsOrBuilder()
The settings to pass to the parallel worker harness.String
getStreamingWorkerMainClass()
The streaming worker main class name.com.google.protobuf.ByteString
getStreamingWorkerMainClassBytes()
The streaming worker main class name.String
getTaskGroup()
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g.com.google.protobuf.ByteString
getTaskGroupBytes()
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g.String
getTaskUser()
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g.com.google.protobuf.ByteString
getTaskUserBytes()
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g.String
getTempStoragePrefix()
The prefix of the resources the taskrunner should use for temporary storage.com.google.protobuf.ByteString
getTempStoragePrefixBytes()
The prefix of the resources the taskrunner should use for temporary storage.String
getVmId()
The ID string of the VM.com.google.protobuf.ByteString
getVmIdBytes()
The ID string of the VM.String
getWorkflowFileName()
The file to store the workflow in.com.google.protobuf.ByteString
getWorkflowFileNameBytes()
The file to store the workflow in.boolean
hasParallelWorkerSettings()
The settings to pass to the parallel worker harness.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
TaskRunnerSettings.Builder
mergeFrom(TaskRunnerSettings other)
TaskRunnerSettings.Builder
mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
TaskRunnerSettings.Builder
mergeFrom(com.google.protobuf.Message other)
TaskRunnerSettings.Builder
mergeParallelWorkerSettings(WorkerSettings value)
The settings to pass to the parallel worker harness.TaskRunnerSettings.Builder
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
TaskRunnerSettings.Builder
setAlsologtostderr(boolean value)
Whether to also send taskrunner log info to stderr.TaskRunnerSettings.Builder
setBaseTaskDir(String value)
The location on the worker for task-specific subdirectories.TaskRunnerSettings.Builder
setBaseTaskDirBytes(com.google.protobuf.ByteString value)
The location on the worker for task-specific subdirectories.TaskRunnerSettings.Builder
setBaseUrl(String value)
The base URL for the taskrunner to use when accessing Google Cloud APIs.TaskRunnerSettings.Builder
setBaseUrlBytes(com.google.protobuf.ByteString value)
The base URL for the taskrunner to use when accessing Google Cloud APIs.TaskRunnerSettings.Builder
setCommandlinesFileName(String value)
The file to store preprocessing commands in.TaskRunnerSettings.Builder
setCommandlinesFileNameBytes(com.google.protobuf.ByteString value)
The file to store preprocessing commands in.TaskRunnerSettings.Builder
setContinueOnException(boolean value)
Whether to continue taskrunner if an exception is hit.TaskRunnerSettings.Builder
setDataflowApiVersion(String value)
The API version of endpoint, e.g.TaskRunnerSettings.Builder
setDataflowApiVersionBytes(com.google.protobuf.ByteString value)
The API version of endpoint, e.g.TaskRunnerSettings.Builder
setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
TaskRunnerSettings.Builder
setHarnessCommand(String value)
The command to launch the worker harness.TaskRunnerSettings.Builder
setHarnessCommandBytes(com.google.protobuf.ByteString value)
The command to launch the worker harness.TaskRunnerSettings.Builder
setLanguageHint(String value)
The suggested backend language.TaskRunnerSettings.Builder
setLanguageHintBytes(com.google.protobuf.ByteString value)
The suggested backend language.TaskRunnerSettings.Builder
setLogDir(String value)
The directory on the VM to store logs.TaskRunnerSettings.Builder
setLogDirBytes(com.google.protobuf.ByteString value)
The directory on the VM to store logs.TaskRunnerSettings.Builder
setLogToSerialconsole(boolean value)
Whether to send taskrunner log info to Google Compute Engine VM serial console.TaskRunnerSettings.Builder
setLogUploadLocation(String value)
Indicates where to put logs.TaskRunnerSettings.Builder
setLogUploadLocationBytes(com.google.protobuf.ByteString value)
Indicates where to put logs.TaskRunnerSettings.Builder
setOauthScopes(int index, String value)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.TaskRunnerSettings.Builder
setParallelWorkerSettings(WorkerSettings value)
The settings to pass to the parallel worker harness.TaskRunnerSettings.Builder
setParallelWorkerSettings(WorkerSettings.Builder builderForValue)
The settings to pass to the parallel worker harness.TaskRunnerSettings.Builder
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
TaskRunnerSettings.Builder
setStreamingWorkerMainClass(String value)
The streaming worker main class name.TaskRunnerSettings.Builder
setStreamingWorkerMainClassBytes(com.google.protobuf.ByteString value)
The streaming worker main class name.TaskRunnerSettings.Builder
setTaskGroup(String value)
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g.TaskRunnerSettings.Builder
setTaskGroupBytes(com.google.protobuf.ByteString value)
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g.TaskRunnerSettings.Builder
setTaskUser(String value)
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g.TaskRunnerSettings.Builder
setTaskUserBytes(com.google.protobuf.ByteString value)
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g.TaskRunnerSettings.Builder
setTempStoragePrefix(String value)
The prefix of the resources the taskrunner should use for temporary storage.TaskRunnerSettings.Builder
setTempStoragePrefixBytes(com.google.protobuf.ByteString value)
The prefix of the resources the taskrunner should use for temporary storage.TaskRunnerSettings.Builder
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
TaskRunnerSettings.Builder
setVmId(String value)
The ID string of the VM.TaskRunnerSettings.Builder
setVmIdBytes(com.google.protobuf.ByteString value)
The ID string of the VM.TaskRunnerSettings.Builder
setWorkflowFileName(String value)
The file to store the workflow in.TaskRunnerSettings.Builder
setWorkflowFileNameBytes(com.google.protobuf.ByteString value)
The file to store the workflow in.-
Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
-
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
clear
public TaskRunnerSettings.Builder clear()
- Specified by:
clear
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clear
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clear
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.Message.Builder
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getDescriptorForType
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
getDefaultInstanceForType
public TaskRunnerSettings getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
build
public TaskRunnerSettings build()
- Specified by:
build
in interfacecom.google.protobuf.Message.Builder
- Specified by:
build
in interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public TaskRunnerSettings buildPartial()
- Specified by:
buildPartial
in interfacecom.google.protobuf.Message.Builder
- Specified by:
buildPartial
in interfacecom.google.protobuf.MessageLite.Builder
-
clone
public TaskRunnerSettings.Builder clone()
- Specified by:
clone
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clone
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clone
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
setField
public TaskRunnerSettings.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
setField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setField
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
clearField
public TaskRunnerSettings.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
- Specified by:
clearField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearField
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
clearOneof
public TaskRunnerSettings.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
- Specified by:
clearOneof
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearOneof
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
setRepeatedField
public TaskRunnerSettings.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
- Specified by:
setRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
addRepeatedField
public TaskRunnerSettings.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
addRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
addRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
mergeFrom
public TaskRunnerSettings.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<TaskRunnerSettings.Builder>
-
mergeFrom
public TaskRunnerSettings.Builder mergeFrom(TaskRunnerSettings other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
mergeFrom
public TaskRunnerSettings.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Specified by:
mergeFrom
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<TaskRunnerSettings.Builder>
- Throws:
IOException
-
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;
- Specified by:
getTaskUser
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The taskUser.
-
getTaskUserBytes
public com.google.protobuf.ByteString getTaskUserBytes()
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
- Specified by:
getTaskUserBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for taskUser.
-
setTaskUser
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;
- Parameters:
value
- The taskUser to set.- Returns:
- 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:
- This builder for chaining.
-
setTaskUserBytes
public TaskRunnerSettings.Builder setTaskUserBytes(com.google.protobuf.ByteString value)
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. "root".
string task_user = 1;
- Parameters:
value
- The bytes for taskUser to set.- Returns:
- This builder for chaining.
-
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;
- Specified by:
getTaskGroup
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The taskGroup.
-
getTaskGroupBytes
public com.google.protobuf.ByteString getTaskGroupBytes()
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
- Specified by:
getTaskGroupBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for taskGroup.
-
setTaskGroup
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;
- Parameters:
value
- The taskGroup to set.- Returns:
- 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:
- This builder for chaining.
-
setTaskGroupBytes
public TaskRunnerSettings.Builder setTaskGroupBytes(com.google.protobuf.ByteString value)
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. "wheel".
string task_group = 2;
- Parameters:
value
- The bytes for taskGroup to set.- Returns:
- This builder for chaining.
-
getOauthScopesList
public com.google.protobuf.ProtocolStringList getOauthScopesList()
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
- Specified by:
getOauthScopesList
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- A list containing the oauthScopes.
-
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;
- Specified by:
getOauthScopesCount
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The count of oauthScopes.
-
getOauthScopes
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;
- Specified by:
getOauthScopes
in interfaceTaskRunnerSettingsOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The oauthScopes at the given index.
-
getOauthScopesBytes
public com.google.protobuf.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;
- Specified by:
getOauthScopesBytes
in interfaceTaskRunnerSettingsOrBuilder
- Parameters:
index
- The index of the value to return.- Returns:
- The bytes of the oauthScopes at the given index.
-
setOauthScopes
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:
index
- The index to set the value at.value
- The oauthScopes to set.- Returns:
- This builder for chaining.
-
addOauthScopes
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;
- Parameters:
value
- The oauthScopes to add.- Returns:
- This builder for chaining.
-
addAllOauthScopes
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;
- Parameters:
values
- The oauthScopes to add.- Returns:
- 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:
- This builder for chaining.
-
addOauthScopesBytes
public TaskRunnerSettings.Builder addOauthScopesBytes(com.google.protobuf.ByteString value)
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
repeated string oauth_scopes = 3;
- Parameters:
value
- The bytes of the oauthScopes to add.- Returns:
- This builder for chaining.
-
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;
- Specified by:
getBaseUrl
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The baseUrl.
-
getBaseUrlBytes
public com.google.protobuf.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;
- Specified by:
getBaseUrlBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for baseUrl.
-
setBaseUrl
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;
- Parameters:
value
- The baseUrl to set.- Returns:
- 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:
- This builder for chaining.
-
setBaseUrlBytes
public TaskRunnerSettings.Builder setBaseUrlBytes(com.google.protobuf.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;
- Parameters:
value
- The bytes for baseUrl to set.- Returns:
- This builder for chaining.
-
getDataflowApiVersion
public String getDataflowApiVersion()
The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
- Specified by:
getDataflowApiVersion
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The dataflowApiVersion.
-
getDataflowApiVersionBytes
public com.google.protobuf.ByteString getDataflowApiVersionBytes()
The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
- Specified by:
getDataflowApiVersionBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for dataflowApiVersion.
-
setDataflowApiVersion
public TaskRunnerSettings.Builder setDataflowApiVersion(String value)
The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
- Parameters:
value
- The dataflowApiVersion to set.- Returns:
- This builder for chaining.
-
clearDataflowApiVersion
public TaskRunnerSettings.Builder clearDataflowApiVersion()
The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
- Returns:
- This builder for chaining.
-
setDataflowApiVersionBytes
public TaskRunnerSettings.Builder setDataflowApiVersionBytes(com.google.protobuf.ByteString value)
The API version of endpoint, e.g. "v1b3"
string dataflow_api_version = 5;
- Parameters:
value
- The bytes for dataflowApiVersion to set.- Returns:
- This builder for chaining.
-
hasParallelWorkerSettings
public boolean hasParallelWorkerSettings()
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
- Specified by:
hasParallelWorkerSettings
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- Whether the parallelWorkerSettings field is set.
-
getParallelWorkerSettings
public WorkerSettings getParallelWorkerSettings()
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
- Specified by:
getParallelWorkerSettings
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The parallelWorkerSettings.
-
setParallelWorkerSettings
public TaskRunnerSettings.Builder setParallelWorkerSettings(WorkerSettings value)
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
-
setParallelWorkerSettings
public TaskRunnerSettings.Builder setParallelWorkerSettings(WorkerSettings.Builder builderForValue)
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
-
mergeParallelWorkerSettings
public TaskRunnerSettings.Builder mergeParallelWorkerSettings(WorkerSettings value)
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
-
clearParallelWorkerSettings
public TaskRunnerSettings.Builder clearParallelWorkerSettings()
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
-
getParallelWorkerSettingsBuilder
public WorkerSettings.Builder getParallelWorkerSettingsBuilder()
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
-
getParallelWorkerSettingsOrBuilder
public WorkerSettingsOrBuilder getParallelWorkerSettingsOrBuilder()
The settings to pass to the parallel worker harness.
.google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
- Specified by:
getParallelWorkerSettingsOrBuilder
in interfaceTaskRunnerSettingsOrBuilder
-
getBaseTaskDir
public String getBaseTaskDir()
The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
- Specified by:
getBaseTaskDir
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The baseTaskDir.
-
getBaseTaskDirBytes
public com.google.protobuf.ByteString getBaseTaskDirBytes()
The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
- Specified by:
getBaseTaskDirBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for baseTaskDir.
-
setBaseTaskDir
public TaskRunnerSettings.Builder setBaseTaskDir(String value)
The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
- Parameters:
value
- The baseTaskDir to set.- Returns:
- This builder for chaining.
-
clearBaseTaskDir
public TaskRunnerSettings.Builder clearBaseTaskDir()
The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
- Returns:
- This builder for chaining.
-
setBaseTaskDirBytes
public TaskRunnerSettings.Builder setBaseTaskDirBytes(com.google.protobuf.ByteString value)
The location on the worker for task-specific subdirectories.
string base_task_dir = 7;
- Parameters:
value
- The bytes for baseTaskDir to set.- Returns:
- This builder for chaining.
-
getContinueOnException
public boolean getContinueOnException()
Whether to continue taskrunner if an exception is hit.
bool continue_on_exception = 8;
- Specified by:
getContinueOnException
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The continueOnException.
-
setContinueOnException
public TaskRunnerSettings.Builder setContinueOnException(boolean value)
Whether to continue taskrunner if an exception is hit.
bool continue_on_exception = 8;
- Parameters:
value
- The continueOnException to set.- Returns:
- This builder for chaining.
-
clearContinueOnException
public TaskRunnerSettings.Builder clearContinueOnException()
Whether to continue taskrunner if an exception is hit.
bool continue_on_exception = 8;
- Returns:
- This builder for chaining.
-
getLogToSerialconsole
public boolean getLogToSerialconsole()
Whether to send taskrunner log info to Google Compute Engine VM serial console.
bool log_to_serialconsole = 9;
- Specified by:
getLogToSerialconsole
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The logToSerialconsole.
-
setLogToSerialconsole
public TaskRunnerSettings.Builder setLogToSerialconsole(boolean value)
Whether to send taskrunner log info to Google Compute Engine VM serial console.
bool log_to_serialconsole = 9;
- Parameters:
value
- The logToSerialconsole to set.- Returns:
- 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:
- This builder for chaining.
-
getAlsologtostderr
public boolean getAlsologtostderr()
Whether to also send taskrunner log info to stderr.
bool alsologtostderr = 10;
- Specified by:
getAlsologtostderr
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The alsologtostderr.
-
setAlsologtostderr
public TaskRunnerSettings.Builder setAlsologtostderr(boolean value)
Whether to also send taskrunner log info to stderr.
bool alsologtostderr = 10;
- Parameters:
value
- The alsologtostderr to set.- Returns:
- This builder for chaining.
-
clearAlsologtostderr
public TaskRunnerSettings.Builder clearAlsologtostderr()
Whether to also send taskrunner log info to stderr.
bool alsologtostderr = 10;
- Returns:
- This builder for chaining.
-
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;
- Specified by:
getLogUploadLocation
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The logUploadLocation.
-
getLogUploadLocationBytes
public com.google.protobuf.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;
- Specified by:
getLogUploadLocationBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for logUploadLocation.
-
setLogUploadLocation
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;
- Parameters:
value
- The logUploadLocation to set.- Returns:
- 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:
- This builder for chaining.
-
setLogUploadLocationBytes
public TaskRunnerSettings.Builder setLogUploadLocationBytes(com.google.protobuf.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;
- Parameters:
value
- The bytes for logUploadLocation to set.- Returns:
- This builder for chaining.
-
getLogDir
public String getLogDir()
The directory on the VM to store logs.
string log_dir = 12;
- Specified by:
getLogDir
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The logDir.
-
getLogDirBytes
public com.google.protobuf.ByteString getLogDirBytes()
The directory on the VM to store logs.
string log_dir = 12;
- Specified by:
getLogDirBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for logDir.
-
setLogDir
public TaskRunnerSettings.Builder setLogDir(String value)
The directory on the VM to store logs.
string log_dir = 12;
- Parameters:
value
- The logDir to set.- Returns:
- This builder for chaining.
-
clearLogDir
public TaskRunnerSettings.Builder clearLogDir()
The directory on the VM to store logs.
string log_dir = 12;
- Returns:
- This builder for chaining.
-
setLogDirBytes
public TaskRunnerSettings.Builder setLogDirBytes(com.google.protobuf.ByteString value)
The directory on the VM to store logs.
string log_dir = 12;
- Parameters:
value
- The bytes for logDir to set.- Returns:
- This builder for chaining.
-
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;
- Specified by:
getTempStoragePrefix
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The tempStoragePrefix.
-
getTempStoragePrefixBytes
public com.google.protobuf.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;
- Specified by:
getTempStoragePrefixBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for tempStoragePrefix.
-
setTempStoragePrefix
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;
- Parameters:
value
- The tempStoragePrefix to set.- Returns:
- 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:
- This builder for chaining.
-
setTempStoragePrefixBytes
public TaskRunnerSettings.Builder setTempStoragePrefixBytes(com.google.protobuf.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;
- Parameters:
value
- The bytes for tempStoragePrefix to set.- Returns:
- This builder for chaining.
-
getHarnessCommand
public String getHarnessCommand()
The command to launch the worker harness.
string harness_command = 14;
- Specified by:
getHarnessCommand
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The harnessCommand.
-
getHarnessCommandBytes
public com.google.protobuf.ByteString getHarnessCommandBytes()
The command to launch the worker harness.
string harness_command = 14;
- Specified by:
getHarnessCommandBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for harnessCommand.
-
setHarnessCommand
public TaskRunnerSettings.Builder setHarnessCommand(String value)
The command to launch the worker harness.
string harness_command = 14;
- Parameters:
value
- The harnessCommand to set.- Returns:
- This builder for chaining.
-
clearHarnessCommand
public TaskRunnerSettings.Builder clearHarnessCommand()
The command to launch the worker harness.
string harness_command = 14;
- Returns:
- This builder for chaining.
-
setHarnessCommandBytes
public TaskRunnerSettings.Builder setHarnessCommandBytes(com.google.protobuf.ByteString value)
The command to launch the worker harness.
string harness_command = 14;
- Parameters:
value
- The bytes for harnessCommand to set.- Returns:
- This builder for chaining.
-
getWorkflowFileName
public String getWorkflowFileName()
The file to store the workflow in.
string workflow_file_name = 15;
- Specified by:
getWorkflowFileName
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The workflowFileName.
-
getWorkflowFileNameBytes
public com.google.protobuf.ByteString getWorkflowFileNameBytes()
The file to store the workflow in.
string workflow_file_name = 15;
- Specified by:
getWorkflowFileNameBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for workflowFileName.
-
setWorkflowFileName
public TaskRunnerSettings.Builder setWorkflowFileName(String value)
The file to store the workflow in.
string workflow_file_name = 15;
- Parameters:
value
- The workflowFileName to set.- Returns:
- This builder for chaining.
-
clearWorkflowFileName
public TaskRunnerSettings.Builder clearWorkflowFileName()
The file to store the workflow in.
string workflow_file_name = 15;
- Returns:
- This builder for chaining.
-
setWorkflowFileNameBytes
public TaskRunnerSettings.Builder setWorkflowFileNameBytes(com.google.protobuf.ByteString value)
The file to store the workflow in.
string workflow_file_name = 15;
- Parameters:
value
- The bytes for workflowFileName to set.- Returns:
- This builder for chaining.
-
getCommandlinesFileName
public String getCommandlinesFileName()
The file to store preprocessing commands in.
string commandlines_file_name = 16;
- Specified by:
getCommandlinesFileName
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The commandlinesFileName.
-
getCommandlinesFileNameBytes
public com.google.protobuf.ByteString getCommandlinesFileNameBytes()
The file to store preprocessing commands in.
string commandlines_file_name = 16;
- Specified by:
getCommandlinesFileNameBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for commandlinesFileName.
-
setCommandlinesFileName
public TaskRunnerSettings.Builder setCommandlinesFileName(String value)
The file to store preprocessing commands in.
string commandlines_file_name = 16;
- Parameters:
value
- The commandlinesFileName to set.- Returns:
- This builder for chaining.
-
clearCommandlinesFileName
public TaskRunnerSettings.Builder clearCommandlinesFileName()
The file to store preprocessing commands in.
string commandlines_file_name = 16;
- Returns:
- This builder for chaining.
-
setCommandlinesFileNameBytes
public TaskRunnerSettings.Builder setCommandlinesFileNameBytes(com.google.protobuf.ByteString value)
The file to store preprocessing commands in.
string commandlines_file_name = 16;
- Parameters:
value
- The bytes for commandlinesFileName to set.- Returns:
- This builder for chaining.
-
getVmId
public String getVmId()
The ID string of the VM.
string vm_id = 17;
- Specified by:
getVmId
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The vmId.
-
getVmIdBytes
public com.google.protobuf.ByteString getVmIdBytes()
The ID string of the VM.
string vm_id = 17;
- Specified by:
getVmIdBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for vmId.
-
setVmId
public TaskRunnerSettings.Builder setVmId(String value)
The ID string of the VM.
string vm_id = 17;
- Parameters:
value
- The vmId to set.- Returns:
- This builder for chaining.
-
clearVmId
public TaskRunnerSettings.Builder clearVmId()
The ID string of the VM.
string vm_id = 17;
- Returns:
- This builder for chaining.
-
setVmIdBytes
public TaskRunnerSettings.Builder setVmIdBytes(com.google.protobuf.ByteString value)
The ID string of the VM.
string vm_id = 17;
- Parameters:
value
- The bytes for vmId to set.- Returns:
- This builder for chaining.
-
getLanguageHint
public String getLanguageHint()
The suggested backend language.
string language_hint = 18;
- Specified by:
getLanguageHint
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The languageHint.
-
getLanguageHintBytes
public com.google.protobuf.ByteString getLanguageHintBytes()
The suggested backend language.
string language_hint = 18;
- Specified by:
getLanguageHintBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for languageHint.
-
setLanguageHint
public TaskRunnerSettings.Builder setLanguageHint(String value)
The suggested backend language.
string language_hint = 18;
- Parameters:
value
- The languageHint to set.- Returns:
- This builder for chaining.
-
clearLanguageHint
public TaskRunnerSettings.Builder clearLanguageHint()
The suggested backend language.
string language_hint = 18;
- Returns:
- This builder for chaining.
-
setLanguageHintBytes
public TaskRunnerSettings.Builder setLanguageHintBytes(com.google.protobuf.ByteString value)
The suggested backend language.
string language_hint = 18;
- Parameters:
value
- The bytes for languageHint to set.- Returns:
- This builder for chaining.
-
getStreamingWorkerMainClass
public String getStreamingWorkerMainClass()
The streaming worker main class name.
string streaming_worker_main_class = 19;
- Specified by:
getStreamingWorkerMainClass
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The streamingWorkerMainClass.
-
getStreamingWorkerMainClassBytes
public com.google.protobuf.ByteString getStreamingWorkerMainClassBytes()
The streaming worker main class name.
string streaming_worker_main_class = 19;
- Specified by:
getStreamingWorkerMainClassBytes
in interfaceTaskRunnerSettingsOrBuilder
- Returns:
- The bytes for streamingWorkerMainClass.
-
setStreamingWorkerMainClass
public TaskRunnerSettings.Builder setStreamingWorkerMainClass(String value)
The streaming worker main class name.
string streaming_worker_main_class = 19;
- Parameters:
value
- The streamingWorkerMainClass to set.- Returns:
- This builder for chaining.
-
clearStreamingWorkerMainClass
public TaskRunnerSettings.Builder clearStreamingWorkerMainClass()
The streaming worker main class name.
string streaming_worker_main_class = 19;
- Returns:
- This builder for chaining.
-
setStreamingWorkerMainClassBytes
public TaskRunnerSettings.Builder setStreamingWorkerMainClassBytes(com.google.protobuf.ByteString value)
The streaming worker main class name.
string streaming_worker_main_class = 19;
- Parameters:
value
- The bytes for streamingWorkerMainClass to set.- Returns:
- This builder for chaining.
-
setUnknownFields
public final TaskRunnerSettings.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
setUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
mergeUnknownFields
public final TaskRunnerSettings.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<TaskRunnerSettings.Builder>
-
-