Interface WorkerSettingsOrBuilder (0.51.0)

public interface WorkerSettingsOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

getBaseUrl()

public abstract 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 abstract 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.

getReportingEnabled()

public abstract boolean getReportingEnabled()

Whether to send work progress updates to the service.

bool reporting_enabled = 2;

Returns
Type Description
boolean

The reportingEnabled.

getServicePath()

public abstract 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 abstract 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 abstract 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 abstract 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 abstract 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 abstract 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 abstract String getWorkerId()

The ID of the worker running this pipeline.

string worker_id = 5;

Returns
Type Description
String

The workerId.

getWorkerIdBytes()

public abstract ByteString getWorkerIdBytes()

The ID of the worker running this pipeline.

string worker_id = 5;

Returns
Type Description
ByteString

The bytes for workerId.