Class WorkerSettings.Builder (0.50.0)

public static final class WorkerSettings.Builder extends GeneratedMessageV3.Builder<WorkerSettings.Builder> implements WorkerSettingsOrBuilder

Provides data to pass through to the worker harness.

Protobuf type google.dataflow.v1beta3.WorkerSettings

Static Methods

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
Type Description
Descriptor

Methods

addRepeatedField(Descriptors.FieldDescriptor field, Object value)

public WorkerSettings.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters
Name Description
field FieldDescriptor
value Object
Returns
Type Description
WorkerSettings.Builder
Overrides

build()

public WorkerSettings build()
Returns
Type Description
WorkerSettings

buildPartial()

public WorkerSettings buildPartial()
Returns
Type Description
WorkerSettings

clear()

public WorkerSettings.Builder clear()
Returns
Type Description
WorkerSettings.Builder
Overrides

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
Type Description
WorkerSettings.Builder

This builder for chaining.

clearField(Descriptors.FieldDescriptor field)

public WorkerSettings.Builder clearField(Descriptors.FieldDescriptor field)
Parameter
Name Description
field FieldDescriptor
Returns
Type Description
WorkerSettings.Builder
Overrides

clearOneof(Descriptors.OneofDescriptor oneof)

public WorkerSettings.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter
Name Description
oneof OneofDescriptor
Returns
Type Description
WorkerSettings.Builder
Overrides

clearReportingEnabled()

public WorkerSettings.Builder clearReportingEnabled()

Whether to send work progress updates to the service.

bool reporting_enabled = 2;

Returns
Type Description
WorkerSettings.Builder

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
Type Description
WorkerSettings.Builder

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
Type Description
WorkerSettings.Builder

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
Type Description
WorkerSettings.Builder

This builder for chaining.

clearWorkerId()

public WorkerSettings.Builder clearWorkerId()

The ID of the worker running this pipeline.

string worker_id = 5;

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

clone()

public WorkerSettings.Builder clone()
Returns
Type Description
WorkerSettings.Builder
Overrides

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;

Returns
Type Description
String

The baseUrl.

getBaseUrlBytes()

public 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
Type Description
ByteString

The bytes for baseUrl.

getDefaultInstanceForType()

public WorkerSettings getDefaultInstanceForType()
Returns
Type Description
WorkerSettings

getDescriptorForType()

public Descriptors.Descriptor getDescriptorForType()
Returns
Type Description
Descriptor
Overrides

getReportingEnabled()

public boolean getReportingEnabled()

Whether to send work progress updates to the service.

bool reporting_enabled = 2;

Returns
Type Description
boolean

The reportingEnabled.

getServicePath()

public String getServicePath()

The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".

string service_path = 3;

Returns
Type Description
String

The servicePath.

getServicePathBytes()

public ByteString getServicePathBytes()

The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".

string service_path = 3;

Returns
Type Description
ByteString

The bytes for servicePath.

getShuffleServicePath()

public String getShuffleServicePath()

The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".

string shuffle_service_path = 4;

Returns
Type Description
String

The shuffleServicePath.

getShuffleServicePathBytes()

public ByteString getShuffleServicePathBytes()

The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".

string shuffle_service_path = 4;

Returns
Type Description
ByteString

The bytes for shuffleServicePath.

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;

Returns
Type Description
String

The tempStoragePrefix.

getTempStoragePrefixBytes()

public 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
Type Description
ByteString

The bytes for tempStoragePrefix.

getWorkerId()

public String getWorkerId()

The ID of the worker running this pipeline.

string worker_id = 5;

Returns
Type Description
String

The workerId.

getWorkerIdBytes()

public ByteString getWorkerIdBytes()

The ID of the worker running this pipeline.

string worker_id = 5;

Returns
Type Description
ByteString

The bytes for workerId.

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Type Description
FieldAccessorTable
Overrides

isInitialized()

public final boolean isInitialized()
Returns
Type Description
boolean
Overrides

mergeFrom(WorkerSettings other)

public WorkerSettings.Builder mergeFrom(WorkerSettings other)
Parameter
Name Description
other WorkerSettings
Returns
Type Description
WorkerSettings.Builder

mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public WorkerSettings.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input CodedInputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
WorkerSettings.Builder
Overrides
Exceptions
Type Description
IOException

mergeFrom(Message other)

public WorkerSettings.Builder mergeFrom(Message other)
Parameter
Name Description
other Message
Returns
Type Description
WorkerSettings.Builder
Overrides

mergeUnknownFields(UnknownFieldSet unknownFields)

public final WorkerSettings.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
Name Description
unknownFields UnknownFieldSet
Returns
Type Description
WorkerSettings.Builder
Overrides

setBaseUrl(String value)

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;

Parameter
Name Description
value String

The baseUrl to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setBaseUrlBytes(ByteString value)

public WorkerSettings.Builder setBaseUrlBytes(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;

Parameter
Name Description
value ByteString

The bytes for baseUrl to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setField(Descriptors.FieldDescriptor field, Object value)

public WorkerSettings.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters
Name Description
field FieldDescriptor
value Object
Returns
Type Description
WorkerSettings.Builder
Overrides

setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)

public WorkerSettings.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Parameters
Name Description
field FieldDescriptor
index int
value Object
Returns
Type Description
WorkerSettings.Builder
Overrides

setReportingEnabled(boolean value)

public WorkerSettings.Builder setReportingEnabled(boolean value)

Whether to send work progress updates to the service.

bool reporting_enabled = 2;

Parameter
Name Description
value boolean

The reportingEnabled to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setServicePath(String value)

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;

Parameter
Name Description
value String

The servicePath to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setServicePathBytes(ByteString value)

public WorkerSettings.Builder setServicePathBytes(ByteString value)

The Cloud Dataflow service path relative to the root URL, for example, "dataflow/v1b3/projects".

string service_path = 3;

Parameter
Name Description
value ByteString

The bytes for servicePath to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setShuffleServicePath(String value)

public WorkerSettings.Builder setShuffleServicePath(String value)

The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".

string shuffle_service_path = 4;

Parameter
Name Description
value String

The shuffleServicePath to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setShuffleServicePathBytes(ByteString value)

public WorkerSettings.Builder setShuffleServicePathBytes(ByteString value)

The Shuffle service path relative to the root URL, for example, "shuffle/v1beta1".

string shuffle_service_path = 4;

Parameter
Name Description
value ByteString

The bytes for shuffleServicePath to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setTempStoragePrefix(String value)

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;

Parameter
Name Description
value String

The tempStoragePrefix to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setTempStoragePrefixBytes(ByteString value)

public WorkerSettings.Builder setTempStoragePrefixBytes(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;

Parameter
Name Description
value ByteString

The bytes for tempStoragePrefix to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setUnknownFields(UnknownFieldSet unknownFields)

public final WorkerSettings.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
Name Description
unknownFields UnknownFieldSet
Returns
Type Description
WorkerSettings.Builder
Overrides

setWorkerId(String value)

public WorkerSettings.Builder setWorkerId(String value)

The ID of the worker running this pipeline.

string worker_id = 5;

Parameter
Name Description
value String

The workerId to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.

setWorkerIdBytes(ByteString value)

public WorkerSettings.Builder setWorkerIdBytes(ByteString value)

The ID of the worker running this pipeline.

string worker_id = 5;

Parameter
Name Description
value ByteString

The bytes for workerId to set.

Returns
Type Description
WorkerSettings.Builder

This builder for chaining.