Package com.google.dataflow.v1beta3

Class WorkerSettings.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<WorkerSettings.Builder>
com.google.dataflow.v1beta3.WorkerSettings.Builder
All Implemented Interfaces:
WorkerSettingsOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
WorkerSettings
public static final class WorkerSettings.Builder extends com.google.protobuf.GeneratedMessage.Builder<WorkerSettings.Builder> implements WorkerSettingsOrBuilder
 Provides data to pass through to the worker harness.
Protobuf type google.dataflow.v1beta3.WorkerSettings

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<WorkerSettings.Builder>

    • clear

      public WorkerSettings.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<WorkerSettings.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<WorkerSettings.Builder>

    • getDefaultInstanceForType

      public WorkerSettings getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public WorkerSettings build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public WorkerSettings buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public WorkerSettings.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<WorkerSettings.Builder>

    • mergeFrom

      public WorkerSettings.Builder mergeFrom(WorkerSettings other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<WorkerSettings.Builder>

    • mergeFrom

      public WorkerSettings.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<WorkerSettings.Builder>
      Throws:
      IOException

    • getBaseUrl

      public 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;
      Specified by:
      getBaseUrl in interface WorkerSettingsOrBuilder
      Returns:
      The baseUrl.

    • getBaseUrlBytes

      public 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;
      Specified by:
      getBaseUrlBytes in interface WorkerSettingsOrBuilder
      Returns:
      The bytes for baseUrl.

    • setBaseUrl

      public WorkerSettings.Builder setBaseUrl(String value)
       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;
      Parameters:
      value - The baseUrl to set.
      Returns:
      This builder for chaining.

    • clearBaseUrl

      public WorkerSettings.Builder clearBaseUrl()
       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:
      This builder for chaining.

    • setBaseUrlBytes

      public WorkerSettings.Builder setBaseUrlBytes(com.google.protobuf.ByteString value)
       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;
      Parameters:
      value - The bytes for baseUrl to set.
      Returns:
      This builder for chaining.

    • getReportingEnabled

      public boolean getReportingEnabled()
       Whether to send work progress updates to the service.
      bool reporting_enabled = 2;
      Specified by:
      getReportingEnabled in interface WorkerSettingsOrBuilder
      Returns:
      The reportingEnabled.

    • setReportingEnabled

      public WorkerSettings.Builder setReportingEnabled(boolean value)
       Whether to send work progress updates to the service.
      bool reporting_enabled = 2;
      Parameters:
      value - The reportingEnabled to set.
      Returns:
      This builder for chaining.

    • clearReportingEnabled

      public WorkerSettings.Builder clearReportingEnabled()
       Whether to send work progress updates to the service.
      bool reporting_enabled = 2;
      Returns:
      This builder for chaining.

    • getServicePath

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

    • getServicePathBytes

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

    • setServicePath

      public WorkerSettings.Builder setServicePath(String value)
       The Cloud Dataflow service path relative to the root URL, for example,
 "dataflow/v1b3/projects".
      string service_path = 3;
      Parameters:
      value - The servicePath to set.
      Returns:
      This builder for chaining.

    • clearServicePath

      public WorkerSettings.Builder clearServicePath()
       The Cloud Dataflow service path relative to the root URL, for example,
 "dataflow/v1b3/projects".
      string service_path = 3;
      Returns:
      This builder for chaining.

    • setServicePathBytes

      public WorkerSettings.Builder setServicePathBytes(com.google.protobuf.ByteString value)
       The Cloud Dataflow service path relative to the root URL, for example,
 "dataflow/v1b3/projects".
      string service_path = 3;
      Parameters:
      value - The bytes for servicePath to set.
      Returns:
      This builder for chaining.

    • getShuffleServicePath

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

    • getShuffleServicePathBytes

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

    • setShuffleServicePath

      public WorkerSettings.Builder setShuffleServicePath(String value)
       The Shuffle service path relative to the root URL, for example,
 "shuffle/v1beta1".
      string shuffle_service_path = 4;
      Parameters:
      value - The shuffleServicePath to set.
      Returns:
      This builder for chaining.

    • clearShuffleServicePath

      public WorkerSettings.Builder clearShuffleServicePath()
       The Shuffle service path relative to the root URL, for example,
 "shuffle/v1beta1".
      string shuffle_service_path = 4;
      Returns:
      This builder for chaining.

    • setShuffleServicePathBytes

      public WorkerSettings.Builder setShuffleServicePathBytes(com.google.protobuf.ByteString value)
       The Shuffle service path relative to the root URL, for example,
 "shuffle/v1beta1".
      string shuffle_service_path = 4;
      Parameters:
      value - The bytes for shuffleServicePath to set.
      Returns:
      This builder for chaining.

    • getWorkerId

      public String getWorkerId()
       The ID of the worker running this pipeline.
      string worker_id = 5;
      Specified by:
      getWorkerId in interface WorkerSettingsOrBuilder
      Returns:
      The workerId.

    • getWorkerIdBytes

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

    • setWorkerId

      public WorkerSettings.Builder setWorkerId(String value)
       The ID of the worker running this pipeline.
      string worker_id = 5;
      Parameters:
      value - The workerId to set.
      Returns:
      This builder for chaining.

    • clearWorkerId

      public WorkerSettings.Builder clearWorkerId()
       The ID of the worker running this pipeline.
      string worker_id = 5;
      Returns:
      This builder for chaining.

    • setWorkerIdBytes

      public WorkerSettings.Builder setWorkerIdBytes(com.google.protobuf.ByteString value)
       The ID of the worker running this pipeline.
      string worker_id = 5;
      Parameters:
      value - The bytes for workerId to set.
      Returns:
      This builder for chaining.

    • getTempStoragePrefix

      public 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;
      Specified by:
      getTempStoragePrefix in interface WorkerSettingsOrBuilder
      Returns:
      The tempStoragePrefix.

    • getTempStoragePrefixBytes

      public 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;
      Specified by:
      getTempStoragePrefixBytes in interface WorkerSettingsOrBuilder
      Returns:
      The bytes for tempStoragePrefix.

    • setTempStoragePrefix

      public WorkerSettings.Builder setTempStoragePrefix(String value)
       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;
      Parameters:
      value - The tempStoragePrefix to set.
      Returns:
      This builder for chaining.

    • clearTempStoragePrefix

      public WorkerSettings.Builder clearTempStoragePrefix()
       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:
      This builder for chaining.

    • setTempStoragePrefixBytes

      public WorkerSettings.Builder setTempStoragePrefixBytes(com.google.protobuf.ByteString value)
       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;
      Parameters:
      value - The bytes for tempStoragePrefix to set.
      Returns:
      This builder for chaining.