Package com.google.dataflow.v1beta3

Interface TaskRunnerSettingsOrBuilder

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

  • Method Details

    • 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.