Package com.google.dataflow.v1beta3

Interface TaskRunnerSettingsOrBuilder

  • All Superinterfaces:
    com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
    All Known Implementing Classes:
    TaskRunnerSettings, TaskRunnerSettings.Builder
    public interface TaskRunnerSettingsOrBuilder
extends com.google.protobuf.MessageOrBuilder

    • Method Detail

      • getTaskUser

        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:
        The taskUser.

      • getTaskUserBytes

        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;
        Returns:
        The bytes for taskUser.

      • getTaskGroup

        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:
        The taskGroup.

      • getTaskGroupBytes

        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;
        Returns:
        The bytes for taskGroup.

      • getOauthScopesList

        List<String> getOauthScopesList()
         The OAuth2 scopes to be requested by the taskrunner in order to
 access the Cloud Dataflow API.
        repeated string oauth_scopes = 3;
        Returns:
        A list containing the oauthScopes.

      • getOauthScopesCount

        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:
        The count of oauthScopes.

      • getOauthScopes

        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;
        Parameters:
        index - The index of the element to return.
        Returns:
        The oauthScopes at the given index.

      • getOauthScopesBytes

        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;
        Parameters:
        index - The index of the value to return.
        Returns:
        The bytes of the oauthScopes at the given index.

      • getBaseUrl

        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:
        The baseUrl.

      • getBaseUrlBytes

        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;
        Returns:
        The bytes for baseUrl.

      • getDataflowApiVersion

        String getDataflowApiVersion()
         The API version of endpoint, e.g. "v1b3"
        string dataflow_api_version = 5;
        Returns:
        The dataflowApiVersion.

      • getDataflowApiVersionBytes

        com.google.protobuf.ByteString getDataflowApiVersionBytes()
         The API version of endpoint, e.g. "v1b3"
        string dataflow_api_version = 5;
        Returns:
        The bytes for dataflowApiVersion.

      • hasParallelWorkerSettings

        boolean hasParallelWorkerSettings()
         The settings to pass to the parallel worker harness.
        .google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
        Returns:
        Whether the parallelWorkerSettings field is set.

      • getParallelWorkerSettings

        WorkerSettings getParallelWorkerSettings()
         The settings to pass to the parallel worker harness.
        .google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;
        Returns:
        The parallelWorkerSettings.

      • getParallelWorkerSettingsOrBuilder

        WorkerSettingsOrBuilder getParallelWorkerSettingsOrBuilder()
         The settings to pass to the parallel worker harness.
        .google.dataflow.v1beta3.WorkerSettings parallel_worker_settings = 6;

      • getBaseTaskDir

        String getBaseTaskDir()
         The location on the worker for task-specific subdirectories.
        string base_task_dir = 7;
        Returns:
        The baseTaskDir.

      • getBaseTaskDirBytes

        com.google.protobuf.ByteString getBaseTaskDirBytes()
         The location on the worker for task-specific subdirectories.
        string base_task_dir = 7;
        Returns:
        The bytes for baseTaskDir.

      • getContinueOnException

        boolean getContinueOnException()
         Whether to continue taskrunner if an exception is hit.
        bool continue_on_exception = 8;
        Returns:
        The continueOnException.

      • getLogToSerialconsole

        boolean getLogToSerialconsole()
         Whether to send taskrunner log info to Google Compute Engine VM serial
 console.
        bool log_to_serialconsole = 9;
        Returns:
        The logToSerialconsole.

      • getAlsologtostderr

        boolean getAlsologtostderr()
         Whether to also send taskrunner log info to stderr.
        bool alsologtostderr = 10;
        Returns:
        The alsologtostderr.

      • getLogUploadLocation

        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:
        The logUploadLocation.

      • getLogUploadLocationBytes

        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;
        Returns:
        The bytes for logUploadLocation.

      • getLogDir

        String getLogDir()
         The directory on the VM to store logs.
        string log_dir = 12;
        Returns:
        The logDir.

      • getLogDirBytes

        com.google.protobuf.ByteString getLogDirBytes()
         The directory on the VM to store logs.
        string log_dir = 12;
        Returns:
        The bytes for logDir.

      • getTempStoragePrefix

        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:
        The tempStoragePrefix.

      • getTempStoragePrefixBytes

        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;
        Returns:
        The bytes for tempStoragePrefix.

      • getHarnessCommand

        String getHarnessCommand()
         The command to launch the worker harness.
        string harness_command = 14;
        Returns:
        The harnessCommand.

      • getHarnessCommandBytes

        com.google.protobuf.ByteString getHarnessCommandBytes()
         The command to launch the worker harness.
        string harness_command = 14;
        Returns:
        The bytes for harnessCommand.

      • getWorkflowFileName

        String getWorkflowFileName()
         The file to store the workflow in.
        string workflow_file_name = 15;
        Returns:
        The workflowFileName.

      • getWorkflowFileNameBytes

        com.google.protobuf.ByteString getWorkflowFileNameBytes()
         The file to store the workflow in.
        string workflow_file_name = 15;
        Returns:
        The bytes for workflowFileName.

      • getCommandlinesFileName

        String getCommandlinesFileName()
         The file to store preprocessing commands in.
        string commandlines_file_name = 16;
        Returns:
        The commandlinesFileName.

      • getCommandlinesFileNameBytes

        com.google.protobuf.ByteString getCommandlinesFileNameBytes()
         The file to store preprocessing commands in.
        string commandlines_file_name = 16;
        Returns:
        The bytes for commandlinesFileName.

      • getVmId

        String getVmId()
         The ID string of the VM.
        string vm_id = 17;
        Returns:
        The vmId.

      • getVmIdBytes

        com.google.protobuf.ByteString getVmIdBytes()
         The ID string of the VM.
        string vm_id = 17;
        Returns:
        The bytes for vmId.

      • getLanguageHint

        String getLanguageHint()
         The suggested backend language.
        string language_hint = 18;
        Returns:
        The languageHint.

      • getLanguageHintBytes

        com.google.protobuf.ByteString getLanguageHintBytes()
         The suggested backend language.
        string language_hint = 18;
        Returns:
        The bytes for languageHint.

      • getStreamingWorkerMainClass

        String getStreamingWorkerMainClass()
         The streaming worker main class name.
        string streaming_worker_main_class = 19;
        Returns:
        The streamingWorkerMainClass.

      • getStreamingWorkerMainClassBytes

        com.google.protobuf.ByteString getStreamingWorkerMainClassBytes()
         The streaming worker main class name.
        string streaming_worker_main_class = 19;
        Returns:
        The bytes for streamingWorkerMainClass.