- 0.55.0 (latest)
- 0.53.0
- 0.52.0
- 0.51.0
- 0.50.0
- 0.49.0
- 0.48.0
- 0.47.0
- 0.46.0
- 0.45.0
- 0.44.0
- 0.43.0
- 0.41.0
- 0.40.0
- 0.39.0
- 0.38.0
- 0.37.0
- 0.36.0
- 0.35.0
- 0.34.0
- 0.33.0
- 0.32.0
- 0.31.0
- 0.28.0
- 0.27.0
- 0.26.0
- 0.25.0
- 0.24.0
- 0.23.0
- 0.22.0
- 0.21.0
- 0.20.0
- 0.19.0
- 0.18.0
- 0.17.0
- 0.16.0
- 0.15.0
- 0.13.0
- 0.12.0
- 0.11.0
- 0.10.0
- 0.9.0
- 0.8.0
- 0.5.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
Inheritance
Object > AbstractMessageLite.Builder<MessageType,BuilderType> > AbstractMessage.Builder<BuilderType> > GeneratedMessageV3.Builder > WorkerSettings.BuilderImplements
WorkerSettingsOrBuilderStatic Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Type | Description |
Descriptor |
Methods
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public WorkerSettings.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Name | Description |
field | FieldDescriptor |
value | Object |
Type | Description |
WorkerSettings.Builder |
build()
public WorkerSettings build()
Type | Description |
WorkerSettings |
buildPartial()
public WorkerSettings buildPartial()
Type | Description |
WorkerSettings |
clear()
public WorkerSettings.Builder clear()
Type | Description |
WorkerSettings.Builder |
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;
Type | Description |
WorkerSettings.Builder | This builder for chaining. |
clearField(Descriptors.FieldDescriptor field)
public WorkerSettings.Builder clearField(Descriptors.FieldDescriptor field)
Name | Description |
field | FieldDescriptor |
Type | Description |
WorkerSettings.Builder |
clearOneof(Descriptors.OneofDescriptor oneof)
public WorkerSettings.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Name | Description |
oneof | OneofDescriptor |
Type | Description |
WorkerSettings.Builder |
clearReportingEnabled()
public WorkerSettings.Builder clearReportingEnabled()
Whether to send work progress updates to the service.
bool reporting_enabled = 2;
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;
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;
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;
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;
Type | Description |
WorkerSettings.Builder | This builder for chaining. |
clone()
public WorkerSettings.Builder clone()
Type | Description |
WorkerSettings.Builder |
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;
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;
Type | Description |
ByteString | The bytes for baseUrl. |
getDefaultInstanceForType()
public WorkerSettings getDefaultInstanceForType()
Type | Description |
WorkerSettings |
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
Type | Description |
Descriptor |
getReportingEnabled()
public boolean getReportingEnabled()
Whether to send work progress updates to the service.
bool reporting_enabled = 2;
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;
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;
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;
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;
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;
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;
Type | Description |
ByteString | The bytes for tempStoragePrefix. |
getWorkerId()
public String getWorkerId()
The ID of the worker running this pipeline.
string worker_id = 5;
Type | Description |
String | The workerId. |
getWorkerIdBytes()
public ByteString getWorkerIdBytes()
The ID of the worker running this pipeline.
string worker_id = 5;
Type | Description |
ByteString | The bytes for workerId. |
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Type | Description |
FieldAccessorTable |
isInitialized()
public final boolean isInitialized()
Type | Description |
boolean |
mergeFrom(WorkerSettings other)
public WorkerSettings.Builder mergeFrom(WorkerSettings other)
Name | Description |
other | WorkerSettings |
Type | Description |
WorkerSettings.Builder |
mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public WorkerSettings.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Name | Description |
input | CodedInputStream |
extensionRegistry | ExtensionRegistryLite |
Type | Description |
WorkerSettings.Builder |
Type | Description |
IOException |
mergeFrom(Message other)
public WorkerSettings.Builder mergeFrom(Message other)
Name | Description |
other | Message |
Type | Description |
WorkerSettings.Builder |
mergeUnknownFields(UnknownFieldSet unknownFields)
public final WorkerSettings.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Name | Description |
unknownFields | UnknownFieldSet |
Type | Description |
WorkerSettings.Builder |
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;
Name | Description |
value | String The baseUrl to set. |
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;
Name | Description |
value | ByteString The bytes for baseUrl to set. |
Type | Description |
WorkerSettings.Builder | This builder for chaining. |
setField(Descriptors.FieldDescriptor field, Object value)
public WorkerSettings.Builder setField(Descriptors.FieldDescriptor field, Object value)
Name | Description |
field | FieldDescriptor |
value | Object |
Type | Description |
WorkerSettings.Builder |
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public WorkerSettings.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Name | Description |
field | FieldDescriptor |
index | int |
value | Object |
Type | Description |
WorkerSettings.Builder |
setReportingEnabled(boolean value)
public WorkerSettings.Builder setReportingEnabled(boolean value)
Whether to send work progress updates to the service.
bool reporting_enabled = 2;
Name | Description |
value | boolean The reportingEnabled to set. |
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;
Name | Description |
value | String The servicePath to set. |
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;
Name | Description |
value | ByteString The bytes for servicePath to set. |
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;
Name | Description |
value | String The shuffleServicePath to set. |
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;
Name | Description |
value | ByteString The bytes for shuffleServicePath to set. |
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;
Name | Description |
value | String The tempStoragePrefix to set. |
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;
Name | Description |
value | ByteString The bytes for tempStoragePrefix to set. |
Type | Description |
WorkerSettings.Builder | This builder for chaining. |
setUnknownFields(UnknownFieldSet unknownFields)
public final WorkerSettings.Builder setUnknownFields(UnknownFieldSet unknownFields)
Name | Description |
unknownFields | UnknownFieldSet |
Type | Description |
WorkerSettings.Builder |
setWorkerId(String value)
public WorkerSettings.Builder setWorkerId(String value)
The ID of the worker running this pipeline.
string worker_id = 5;
Name | Description |
value | String The workerId to set. |
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;
Name | Description |
value | ByteString The bytes for workerId to set. |
Type | Description |
WorkerSettings.Builder | This builder for chaining. |