Package com.google.dataflow.v1beta3

Interface WorkerSettingsOrBuilder

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

  • Method Summary

    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 Details

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