Uses of Class
com.google.dataflow.v1beta3.TaskRunnerSettings.Builder
-
Uses of TaskRunnerSettings.Builder in com.google.dataflow.v1beta3
Methods in com.google.dataflow.v1beta3 that return TaskRunnerSettings.BuilderModifier and TypeMethodDescriptionTaskRunnerSettings.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.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.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.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.WorkerPool.Builder.getTaskrunnerSettingsBuilder()Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.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.static TaskRunnerSettings.BuilderTaskRunnerSettings.newBuilder()static TaskRunnerSettings.BuilderTaskRunnerSettings.newBuilder(TaskRunnerSettings prototype) TaskRunnerSettings.newBuilderForType()protected TaskRunnerSettings.BuilderTaskRunnerSettings.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) 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.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.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.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.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.TaskRunnerSettings.toBuilder()Methods in com.google.dataflow.v1beta3 with parameters of type TaskRunnerSettings.BuilderModifier and TypeMethodDescriptionWorkerPool.Builder.setTaskrunnerSettings(TaskRunnerSettings.Builder builderForValue) Settings passed through to Google Compute Engine workers when using the standard Dataflow task runner.