Package com.google.dataflow.v1beta3

Interface WorkerSettingsOrBuilder

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

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      String getBaseUrl()
      The base URL for accessing Google Cloud APIs.
      com.google.protobuf.ByteString getBaseUrlBytes()
      The base URL for accessing Google Cloud APIs.
      boolean getReportingEnabled()
      Whether to send work progress updates to the service.
      String getServicePath()
      The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".
      com.google.protobuf.ByteString getServicePathBytes()
      The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".
      String getShuffleServicePath()
      The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".
      com.google.protobuf.ByteString getShuffleServicePathBytes()
      The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".
      String getTempStoragePrefix()
      The prefix of the resources the system should use for temporary storage.
      com.google.protobuf.ByteString getTempStoragePrefixBytes()
      The prefix of the resources the system should use for temporary storage.
      String getWorkerId()
      The ID of the worker running this pipeline.
      com.google.protobuf.ByteString getWorkerIdBytes()
      The ID of the worker running this pipeline.

      • Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

        isInitialized

      • Methods inherited from interface com.google.protobuf.MessageOrBuilder

        findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

    • Method Detail

      • getBaseUrl

        String getBaseUrl()
         The base URL for 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 = 1;
        Returns:
        The baseUrl.

      • getBaseUrlBytes

        com.google.protobuf.ByteString getBaseUrlBytes()
         The base URL for 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 = 1;
        Returns:
        The bytes for baseUrl.

      • getReportingEnabled

        boolean getReportingEnabled()
         Whether to send work progress updates to the service.
        bool reporting_enabled = 2;
        Returns:
        The reportingEnabled.

      • getServicePath

        String getServicePath()
         The Cloud Dataflow service path relative to the root URL, for example,
 "dataflow/v1b3/projects".
        string service_path = 3;
        Returns:
        The servicePath.

      • getServicePathBytes

        com.google.protobuf.ByteString getServicePathBytes()
         The Cloud Dataflow service path relative to the root URL, for example,
 "dataflow/v1b3/projects".
        string service_path = 3;
        Returns:
        The bytes for servicePath.

      • getShuffleServicePath

        String getShuffleServicePath()
         The Shuffle service path relative to the root URL, for example,
 "shuffle/v1beta1".
        string shuffle_service_path = 4;
        Returns:
        The shuffleServicePath.

      • getShuffleServicePathBytes

        com.google.protobuf.ByteString getShuffleServicePathBytes()
         The Shuffle service path relative to the root URL, for example,
 "shuffle/v1beta1".
        string shuffle_service_path = 4;
        Returns:
        The bytes for shuffleServicePath.

      • getWorkerId

        String getWorkerId()
         The ID of the worker running this pipeline.
        string worker_id = 5;
        Returns:
        The workerId.

      • getWorkerIdBytes

        com.google.protobuf.ByteString getWorkerIdBytes()
         The ID of the worker running this pipeline.
        string worker_id = 5;
        Returns:
        The bytes for workerId.

      • getTempStoragePrefix

        String getTempStoragePrefix()
         The prefix of the resources the system 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 = 6;
        Returns:
        The tempStoragePrefix.

      • getTempStoragePrefixBytes

        com.google.protobuf.ByteString getTempStoragePrefixBytes()
         The prefix of the resources the system 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 = 6;
        Returns:
        The bytes for tempStoragePrefix.