public final class RuntimeEnvironment extends GeneratedMessageV3 implements RuntimeEnvironmentOrBuilder
The environment values to set at runtime.
Protobuf type google.dataflow.v1beta3.RuntimeEnvironment
Static Fields
ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
public static final int ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
Field Value
ADDITIONAL_USER_LABELS_FIELD_NUMBER
public static final int ADDITIONAL_USER_LABELS_FIELD_NUMBER
Field Value
BYPASS_TEMP_DIR_VALIDATION_FIELD_NUMBER
public static final int BYPASS_TEMP_DIR_VALIDATION_FIELD_NUMBER
Field Value
ENABLE_STREAMING_ENGINE_FIELD_NUMBER
public static final int ENABLE_STREAMING_ENGINE_FIELD_NUMBER
Field Value
IP_CONFIGURATION_FIELD_NUMBER
public static final int IP_CONFIGURATION_FIELD_NUMBER
Field Value
KMS_KEY_NAME_FIELD_NUMBER
public static final int KMS_KEY_NAME_FIELD_NUMBER
Field Value
MACHINE_TYPE_FIELD_NUMBER
public static final int MACHINE_TYPE_FIELD_NUMBER
Field Value
MAX_WORKERS_FIELD_NUMBER
public static final int MAX_WORKERS_FIELD_NUMBER
Field Value
NETWORK_FIELD_NUMBER
public static final int NETWORK_FIELD_NUMBER
Field Value
NUM_WORKERS_FIELD_NUMBER
public static final int NUM_WORKERS_FIELD_NUMBER
Field Value
SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
Field Value
SUBNETWORK_FIELD_NUMBER
public static final int SUBNETWORK_FIELD_NUMBER
Field Value
TEMP_LOCATION_FIELD_NUMBER
public static final int TEMP_LOCATION_FIELD_NUMBER
Field Value
WORKER_REGION_FIELD_NUMBER
public static final int WORKER_REGION_FIELD_NUMBER
Field Value
WORKER_ZONE_FIELD_NUMBER
public static final int WORKER_ZONE_FIELD_NUMBER
Field Value
ZONE_FIELD_NUMBER
public static final int ZONE_FIELD_NUMBER
Field Value
Static Methods
getDefaultInstance()
public static RuntimeEnvironment getDefaultInstance()
Returns
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Returns
newBuilder()
public static RuntimeEnvironment.Builder newBuilder()
Returns
newBuilder(RuntimeEnvironment prototype)
public static RuntimeEnvironment.Builder newBuilder(RuntimeEnvironment prototype)
Parameter
Returns
public static RuntimeEnvironment parseDelimitedFrom(InputStream input)
Parameter
Returns
Exceptions
public static RuntimeEnvironment parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(byte[] data)
public static RuntimeEnvironment parseFrom(byte[] data)
Parameter
| Name | Description |
| data | byte[]
|
Returns
Exceptions
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static RuntimeEnvironment parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteString data)
public static RuntimeEnvironment parseFrom(ByteString data)
Parameter
Returns
Exceptions
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static RuntimeEnvironment parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static RuntimeEnvironment parseFrom(CodedInputStream input)
Parameter
Returns
Exceptions
public static RuntimeEnvironment parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static RuntimeEnvironment parseFrom(InputStream input)
Parameter
Returns
Exceptions
public static RuntimeEnvironment parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteBuffer data)
public static RuntimeEnvironment parseFrom(ByteBuffer data)
Parameter
Returns
Exceptions
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static RuntimeEnvironment parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parser()
public static Parser<RuntimeEnvironment> parser()
Returns
Methods
containsAdditionalUserLabels(String key)
public boolean containsAdditionalUserLabels(String key)
Additional user labels to be specified for the job.
Keys and values should follow the restrictions specified in the labeling
restrictions
page.
An object containing a list of "key": value pairs.
Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
map<string, string> additional_user_labels = 10;
equals(Object obj)
public boolean equals(Object obj)
Parameter
Returns
Overrides
getAdditionalExperiments(int index)
public String getAdditionalExperiments(int index)
Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Name | Description |
| index | int
The index of the element to return.
|
Returns
| Type | Description |
| String | The additionalExperiments at the given index.
|
getAdditionalExperimentsBytes(int index)
public ByteString getAdditionalExperimentsBytes(int index)
Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Name | Description |
| index | int
The index of the value to return.
|
Returns
| Type | Description |
| ByteString | The bytes of the additionalExperiments at the given index.
|
getAdditionalExperimentsCount()
public int getAdditionalExperimentsCount()
Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
| Type | Description |
| int | The count of additionalExperiments.
|
getAdditionalExperimentsList()
public ProtocolStringList getAdditionalExperimentsList()
Additional experiment flags for the job, specified with the
--experiments option.
repeated string additional_experiments = 7;
getAdditionalUserLabels()
public Map<String,String> getAdditionalUserLabels()
Returns
getAdditionalUserLabelsCount()
public int getAdditionalUserLabelsCount()
Additional user labels to be specified for the job.
Keys and values should follow the restrictions specified in the labeling
restrictions
page.
An object containing a list of "key": value pairs.
Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
map<string, string> additional_user_labels = 10;
getAdditionalUserLabelsMap()
public Map<String,String> getAdditionalUserLabelsMap()
Additional user labels to be specified for the job.
Keys and values should follow the restrictions specified in the labeling
restrictions
page.
An object containing a list of "key": value pairs.
Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
map<string, string> additional_user_labels = 10;
getAdditionalUserLabelsOrDefault(String key, String defaultValue)
public String getAdditionalUserLabelsOrDefault(String key, String defaultValue)
Additional user labels to be specified for the job.
Keys and values should follow the restrictions specified in the labeling
restrictions
page.
An object containing a list of "key": value pairs.
Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
map<string, string> additional_user_labels = 10;
getAdditionalUserLabelsOrThrow(String key)
public String getAdditionalUserLabelsOrThrow(String key)
Additional user labels to be specified for the job.
Keys and values should follow the restrictions specified in the labeling
restrictions
page.
An object containing a list of "key": value pairs.
Example: { "name": "wrench", "mass": "1kg", "count": "3" }.
map<string, string> additional_user_labels = 10;
getBypassTempDirValidation()
public boolean getBypassTempDirValidation()
Whether to bypass the safety checks for the job's temporary directory.
Use with caution.
bool bypass_temp_dir_validation = 5;
| Type | Description |
| boolean | The bypassTempDirValidation.
|
getDefaultInstanceForType()
public RuntimeEnvironment getDefaultInstanceForType()
Returns
getEnableStreamingEngine()
public boolean getEnableStreamingEngine()
Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 17;
| Type | Description |
| boolean | The enableStreamingEngine.
|
getIpConfiguration()
public WorkerIPAddressConfiguration getIpConfiguration()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
getIpConfigurationValue()
public int getIpConfigurationValue()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;
| Type | Description |
| int | The enum numeric value on the wire for ipConfiguration.
|
getKmsKeyName()
public String getKmsKeyName()
Name for the Cloud KMS key for the job.
Key format is:
projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
string kms_key_name = 12;
| Type | Description |
| String | The kmsKeyName.
|
getKmsKeyNameBytes()
public ByteString getKmsKeyNameBytes()
Name for the Cloud KMS key for the job.
Key format is:
projects/<project>/locations/<location>/keyRings/<keyring>/cryptoKeys/<key>
string kms_key_name = 12;
| Type | Description |
| ByteString | The bytes for kmsKeyName.
|
getMachineType()
public String getMachineType()
The machine type to use for the job. Defaults to the value from the
template if not specified.
string machine_type = 6;
| Type | Description |
| String | The machineType.
|
getMachineTypeBytes()
public ByteString getMachineTypeBytes()
The machine type to use for the job. Defaults to the value from the
template if not specified.
string machine_type = 6;
| Type | Description |
| ByteString | The bytes for machineType.
|
getMaxWorkers()
public int getMaxWorkers()
The maximum number of Google Compute Engine instances to be made
available to your pipeline during execution, from 1 to 1000.
int32 max_workers = 1;
| Type | Description |
| int | The maxWorkers.
|
getNetwork()
public String getNetwork()
Network to which VMs will be assigned. If empty or unspecified,
the service will use the network "default".
string network = 8;
| Type | Description |
| String | The network.
|
getNetworkBytes()
public ByteString getNetworkBytes()
Network to which VMs will be assigned. If empty or unspecified,
the service will use the network "default".
string network = 8;
getNumWorkers()
public int getNumWorkers()
The initial number of Google Compute Engine instnaces for the job.
int32 num_workers = 11;
| Type | Description |
| int | The numWorkers.
|
getParserForType()
public Parser<RuntimeEnvironment> getParserForType()
Returns
Overrides
getSerializedSize()
public int getSerializedSize()
Returns
Overrides
getServiceAccountEmail()
public String getServiceAccountEmail()
The email address of the service account to run the job as.
string service_account_email = 3;
| Type | Description |
| String | The serviceAccountEmail.
|
getServiceAccountEmailBytes()
public ByteString getServiceAccountEmailBytes()
The email address of the service account to run the job as.
string service_account_email = 3;
| Type | Description |
| ByteString | The bytes for serviceAccountEmail.
|
getSubnetwork()
public String getSubnetwork()
Returns
| Type | Description |
| String | The subnetwork.
|
getSubnetworkBytes()
public ByteString getSubnetworkBytes()
Returns
| Type | Description |
| ByteString | The bytes for subnetwork.
|
getTempLocation()
public String getTempLocation()
The Cloud Storage path to use for temporary files.
Must be a valid Cloud Storage URL, beginning with gs://.
string temp_location = 4;
| Type | Description |
| String | The tempLocation.
|
getTempLocationBytes()
public ByteString getTempLocationBytes()
The Cloud Storage path to use for temporary files.
Must be a valid Cloud Storage URL, beginning with gs://.
string temp_location = 4;
| Type | Description |
| ByteString | The bytes for tempLocation.
|
getUnknownFields()
public final UnknownFieldSet getUnknownFields()
Returns
Overrides
getWorkerRegion()
public String getWorkerRegion()
Returns
| Type | Description |
| String | The workerRegion.
|
getWorkerRegionBytes()
public ByteString getWorkerRegionBytes()
Returns
| Type | Description |
| ByteString | The bytes for workerRegion.
|
getWorkerZone()
public String getWorkerZone()
The Compute Engine zone
(https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
with worker_region. If neither worker_region nor worker_zone is specified,
a zone in the control plane's region is chosen based on available capacity.
If both worker_zone and zone are set, worker_zone takes precedence.
string worker_zone = 16;
| Type | Description |
| String | The workerZone.
|
getWorkerZoneBytes()
public ByteString getWorkerZoneBytes()
The Compute Engine zone
(https://cloud.google.com/compute/docs/regions-zones/regions-zones) in
which worker processing should occur, e.g. "us-west1-a". Mutually exclusive
with worker_region. If neither worker_region nor worker_zone is specified,
a zone in the control plane's region is chosen based on available capacity.
If both worker_zone and zone are set, worker_zone takes precedence.
string worker_zone = 16;
| Type | Description |
| ByteString | The bytes for workerZone.
|
getZone()
The Compute Engine availability
zone
for launching worker instances to run your pipeline.
In the future, worker_zone will take precedence.
string zone = 2;
| Type | Description |
| String | The zone.
|
getZoneBytes()
public ByteString getZoneBytes()
The Compute Engine availability
zone
for launching worker instances to run your pipeline.
In the future, worker_zone will take precedence.
string zone = 2;
hashCode()
Returns
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Overrides
internalGetMapField(int number)
protected MapField internalGetMapField(int number)
Parameter
Returns
Overrides
isInitialized()
public final boolean isInitialized()
Returns
Overrides
newBuilderForType()
public RuntimeEnvironment.Builder newBuilderForType()
Returns
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected RuntimeEnvironment.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
Returns
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
Returns
Overrides
toBuilder()
public RuntimeEnvironment.Builder toBuilder()
Returns
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Parameter
Overrides
Exceptions
