Package com.google.dataflow.v1beta3
Class FlexTemplateRuntimeEnvironment
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment
-
- All Implemented Interfaces:
FlexTemplateRuntimeEnvironmentOrBuilder
,com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
public final class FlexTemplateRuntimeEnvironment extends com.google.protobuf.GeneratedMessageV3 implements FlexTemplateRuntimeEnvironmentOrBuilder
The environment values to be set at runtime for flex template.
Protobuf typegoogle.dataflow.v1beta3.FlexTemplateRuntimeEnvironment
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FlexTemplateRuntimeEnvironment.Builder
The environment values to be set at runtime for flex template.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static int
ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
static int
ADDITIONAL_USER_LABELS_FIELD_NUMBER
static int
AUTOSCALING_ALGORITHM_FIELD_NUMBER
static int
DISK_SIZE_GB_FIELD_NUMBER
static int
DUMP_HEAP_ON_OOM_FIELD_NUMBER
static int
ENABLE_STREAMING_ENGINE_FIELD_NUMBER
static int
FLEXRS_GOAL_FIELD_NUMBER
static int
IP_CONFIGURATION_FIELD_NUMBER
static int
KMS_KEY_NAME_FIELD_NUMBER
static int
LAUNCHER_MACHINE_TYPE_FIELD_NUMBER
static int
MACHINE_TYPE_FIELD_NUMBER
static int
MAX_WORKERS_FIELD_NUMBER
static int
NETWORK_FIELD_NUMBER
static int
NUM_WORKERS_FIELD_NUMBER
static int
SAVE_HEAP_DUMPS_TO_GCS_PATH_FIELD_NUMBER
static int
SDK_CONTAINER_IMAGE_FIELD_NUMBER
static int
SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
static int
STAGING_LOCATION_FIELD_NUMBER
static int
SUBNETWORK_FIELD_NUMBER
static int
TEMP_LOCATION_FIELD_NUMBER
static int
WORKER_REGION_FIELD_NUMBER
static int
WORKER_ZONE_FIELD_NUMBER
static int
ZONE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
containsAdditionalUserLabels(String key)
Additional user labels to be specified for the job.boolean
equals(Object obj)
String
getAdditionalExperiments(int index)
Additional experiment flags for the job.com.google.protobuf.ByteString
getAdditionalExperimentsBytes(int index)
Additional experiment flags for the job.int
getAdditionalExperimentsCount()
Additional experiment flags for the job.com.google.protobuf.ProtocolStringList
getAdditionalExperimentsList()
Additional experiment flags for the job.Map<String,String>
getAdditionalUserLabels()
Deprecated.int
getAdditionalUserLabelsCount()
Additional user labels to be specified for the job.Map<String,String>
getAdditionalUserLabelsMap()
Additional user labels to be specified for the job.String
getAdditionalUserLabelsOrDefault(String key, String defaultValue)
Additional user labels to be specified for the job.String
getAdditionalUserLabelsOrThrow(String key)
Additional user labels to be specified for the job.AutoscalingAlgorithm
getAutoscalingAlgorithm()
The algorithm to use for autoscalingint
getAutoscalingAlgorithmValue()
The algorithm to use for autoscalingstatic FlexTemplateRuntimeEnvironment
getDefaultInstance()
FlexTemplateRuntimeEnvironment
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
int
getDiskSizeGb()
Worker disk size, in gigabytes.boolean
getDumpHeapOnOom()
If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory.boolean
getEnableStreamingEngine()
Whether to enable Streaming Engine for the job.FlexResourceSchedulingGoal
getFlexrsGoal()
Set FlexRS goal for the job.int
getFlexrsGoalValue()
Set FlexRS goal for the job.WorkerIPAddressConfiguration
getIpConfiguration()
Configuration for VM IPs.int
getIpConfigurationValue()
Configuration for VM IPs.String
getKmsKeyName()
Name for the Cloud KMS key for the job.com.google.protobuf.ByteString
getKmsKeyNameBytes()
Name for the Cloud KMS key for the job.String
getLauncherMachineType()
The machine type to use for launching the job.com.google.protobuf.ByteString
getLauncherMachineTypeBytes()
The machine type to use for launching the job.String
getMachineType()
The machine type to use for the job.com.google.protobuf.ByteString
getMachineTypeBytes()
The machine type to use for the job.int
getMaxWorkers()
The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.String
getNetwork()
Network to which VMs will be assigned.com.google.protobuf.ByteString
getNetworkBytes()
Network to which VMs will be assigned.int
getNumWorkers()
The initial number of Google Compute Engine instances for the job.com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment>
getParserForType()
String
getSaveHeapDumpsToGcsPath()
Cloud Storage bucket (directory) to upload heap dumps to the given location.com.google.protobuf.ByteString
getSaveHeapDumpsToGcsPathBytes()
Cloud Storage bucket (directory) to upload heap dumps to the given location.String
getSdkContainerImage()
Docker registry location of container image to use for the 'worker harness.com.google.protobuf.ByteString
getSdkContainerImageBytes()
Docker registry location of container image to use for the 'worker harness.int
getSerializedSize()
String
getServiceAccountEmail()
The email address of the service account to run the job as.com.google.protobuf.ByteString
getServiceAccountEmailBytes()
The email address of the service account to run the job as.String
getStagingLocation()
The Cloud Storage path for staging local files.com.google.protobuf.ByteString
getStagingLocationBytes()
The Cloud Storage path for staging local files.String
getSubnetwork()
Subnetwork to which VMs will be assigned, if desired.com.google.protobuf.ByteString
getSubnetworkBytes()
Subnetwork to which VMs will be assigned, if desired.String
getTempLocation()
The Cloud Storage path to use for temporary files.com.google.protobuf.ByteString
getTempLocationBytes()
The Cloud Storage path to use for temporary files.String
getWorkerRegion()
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.com.google.protobuf.ByteString
getWorkerRegionBytes()
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.String
getWorkerZone()
The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.com.google.protobuf.ByteString
getWorkerZoneBytes()
The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.String
getZone()
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.com.google.protobuf.ByteString
getZoneBytes()
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.int
hashCode()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
protected com.google.protobuf.MapField
internalGetMapField(int number)
boolean
isInitialized()
static FlexTemplateRuntimeEnvironment.Builder
newBuilder()
static FlexTemplateRuntimeEnvironment.Builder
newBuilder(FlexTemplateRuntimeEnvironment prototype)
FlexTemplateRuntimeEnvironment.Builder
newBuilderForType()
protected FlexTemplateRuntimeEnvironment.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static FlexTemplateRuntimeEnvironment
parseDelimitedFrom(InputStream input)
static FlexTemplateRuntimeEnvironment
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlexTemplateRuntimeEnvironment
parseFrom(byte[] data)
static FlexTemplateRuntimeEnvironment
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlexTemplateRuntimeEnvironment
parseFrom(com.google.protobuf.ByteString data)
static FlexTemplateRuntimeEnvironment
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlexTemplateRuntimeEnvironment
parseFrom(com.google.protobuf.CodedInputStream input)
static FlexTemplateRuntimeEnvironment
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlexTemplateRuntimeEnvironment
parseFrom(InputStream input)
static FlexTemplateRuntimeEnvironment
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlexTemplateRuntimeEnvironment
parseFrom(ByteBuffer data)
static FlexTemplateRuntimeEnvironment
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment>
parser()
FlexTemplateRuntimeEnvironment.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
NUM_WORKERS_FIELD_NUMBER
public static final int NUM_WORKERS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MAX_WORKERS_FIELD_NUMBER
public static final int MAX_WORKERS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ZONE_FIELD_NUMBER
public static final int ZONE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TEMP_LOCATION_FIELD_NUMBER
public static final int TEMP_LOCATION_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MACHINE_TYPE_FIELD_NUMBER
public static final int MACHINE_TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
public static final int ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
NETWORK_FIELD_NUMBER
public static final int NETWORK_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SUBNETWORK_FIELD_NUMBER
public static final int SUBNETWORK_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ADDITIONAL_USER_LABELS_FIELD_NUMBER
public static final int ADDITIONAL_USER_LABELS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
KMS_KEY_NAME_FIELD_NUMBER
public static final int KMS_KEY_NAME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
IP_CONFIGURATION_FIELD_NUMBER
public static final int IP_CONFIGURATION_FIELD_NUMBER
- See Also:
- Constant Field Values
-
WORKER_REGION_FIELD_NUMBER
public static final int WORKER_REGION_FIELD_NUMBER
- See Also:
- Constant Field Values
-
WORKER_ZONE_FIELD_NUMBER
public static final int WORKER_ZONE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ENABLE_STREAMING_ENGINE_FIELD_NUMBER
public static final int ENABLE_STREAMING_ENGINE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
FLEXRS_GOAL_FIELD_NUMBER
public static final int FLEXRS_GOAL_FIELD_NUMBER
- See Also:
- Constant Field Values
-
STAGING_LOCATION_FIELD_NUMBER
public static final int STAGING_LOCATION_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SDK_CONTAINER_IMAGE_FIELD_NUMBER
public static final int SDK_CONTAINER_IMAGE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DISK_SIZE_GB_FIELD_NUMBER
public static final int DISK_SIZE_GB_FIELD_NUMBER
- See Also:
- Constant Field Values
-
AUTOSCALING_ALGORITHM_FIELD_NUMBER
public static final int AUTOSCALING_ALGORITHM_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DUMP_HEAP_ON_OOM_FIELD_NUMBER
public static final int DUMP_HEAP_ON_OOM_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SAVE_HEAP_DUMPS_TO_GCS_PATH_FIELD_NUMBER
public static final int SAVE_HEAP_DUMPS_TO_GCS_PATH_FIELD_NUMBER
- See Also:
- Constant Field Values
-
LAUNCHER_MACHINE_TYPE_FIELD_NUMBER
public static final int LAUNCHER_MACHINE_TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetMapField
protected com.google.protobuf.MapField internalGetMapField(int number)
- Overrides:
internalGetMapField
in classcom.google.protobuf.GeneratedMessageV3
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
getNumWorkers
public int getNumWorkers()
The initial number of Google Compute Engine instances for the job.
int32 num_workers = 1;
- Specified by:
getNumWorkers
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The numWorkers.
-
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 = 2;
- Specified by:
getMaxWorkers
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The maxWorkers.
-
getZone
public String getZone()
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;
- Specified by:
getZone
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The zone.
-
getZoneBytes
public com.google.protobuf.ByteString getZoneBytes()
The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline. In the future, worker_zone will take precedence.
string zone = 3;
- Specified by:
getZoneBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for zone.
-
getServiceAccountEmail
public String getServiceAccountEmail()
The email address of the service account to run the job as.
string service_account_email = 4;
- Specified by:
getServiceAccountEmail
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The serviceAccountEmail.
-
getServiceAccountEmailBytes
public com.google.protobuf.ByteString getServiceAccountEmailBytes()
The email address of the service account to run the job as.
string service_account_email = 4;
- Specified by:
getServiceAccountEmailBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for serviceAccountEmail.
-
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 = 5;
- Specified by:
getTempLocation
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The tempLocation.
-
getTempLocationBytes
public com.google.protobuf.ByteString getTempLocationBytes()
The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 5;
- Specified by:
getTempLocationBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for tempLocation.
-
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;
- Specified by:
getMachineType
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The machineType.
-
getMachineTypeBytes
public com.google.protobuf.ByteString getMachineTypeBytes()
The machine type to use for the job. Defaults to the value from the template if not specified.
string machine_type = 6;
- Specified by:
getMachineTypeBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for machineType.
-
getAdditionalExperimentsList
public com.google.protobuf.ProtocolStringList getAdditionalExperimentsList()
Additional experiment flags for the job.
repeated string additional_experiments = 7;
- Specified by:
getAdditionalExperimentsList
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- A list containing the additionalExperiments.
-
getAdditionalExperimentsCount
public int getAdditionalExperimentsCount()
Additional experiment flags for the job.
repeated string additional_experiments = 7;
- Specified by:
getAdditionalExperimentsCount
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The count of additionalExperiments.
-
getAdditionalExperiments
public String getAdditionalExperiments(int index)
Additional experiment flags for the job.
repeated string additional_experiments = 7;
- Specified by:
getAdditionalExperiments
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The additionalExperiments at the given index.
-
getAdditionalExperimentsBytes
public com.google.protobuf.ByteString getAdditionalExperimentsBytes(int index)
Additional experiment flags for the job.
repeated string additional_experiments = 7;
- Specified by:
getAdditionalExperimentsBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Parameters:
index
- The index of the value to return.- Returns:
- The bytes of the additionalExperiments at the given index.
-
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;
- Specified by:
getNetwork
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The network.
-
getNetworkBytes
public com.google.protobuf.ByteString getNetworkBytes()
Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;
- Specified by:
getNetworkBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for network.
-
getSubnetwork
public String getSubnetwork()
Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
string subnetwork = 9;
- Specified by:
getSubnetwork
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The subnetwork.
-
getSubnetworkBytes
public com.google.protobuf.ByteString getSubnetworkBytes()
Subnetwork to which VMs will be assigned, if desired. You can specify a subnetwork using either a complete URL or an abbreviated path. Expected to be of the form "https://www.googleapis.com/compute/v1/projects/HOST_PROJECT_ID/regions/REGION/subnetworks/SUBNETWORK" or "regions/REGION/subnetworks/SUBNETWORK". If the subnetwork is located in a Shared VPC network, you must use the complete URL.
string subnetwork = 9;
- Specified by:
getSubnetworkBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for subnetwork.
-
getAdditionalUserLabelsCount
public int getAdditionalUserLabelsCount()
Description copied from interface:FlexTemplateRuntimeEnvironmentOrBuilder
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
- Specified by:
getAdditionalUserLabelsCount
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
containsAdditionalUserLabels
public boolean containsAdditionalUserLabels(String key)
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
- Specified by:
containsAdditionalUserLabels
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabels
@Deprecated public Map<String,String> getAdditionalUserLabels()
Deprecated.UsegetAdditionalUserLabelsMap()
instead.- Specified by:
getAdditionalUserLabels
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsMap
public Map<String,String> getAdditionalUserLabelsMap()
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
- Specified by:
getAdditionalUserLabelsMap
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsOrDefault
public String getAdditionalUserLabelsOrDefault(String key, String defaultValue)
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
- Specified by:
getAdditionalUserLabelsOrDefault
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsOrThrow
public String getAdditionalUserLabelsOrThrow(String key)
Additional user labels to be specified for the job. Keys and values must follow the restrictions specified in the [labeling restrictions](https://cloud.google.com/compute/docs/labeling-resources#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;
- Specified by:
getAdditionalUserLabelsOrThrow
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
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 = 11;
- Specified by:
getKmsKeyName
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The kmsKeyName.
-
getKmsKeyNameBytes
public com.google.protobuf.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 = 11;
- Specified by:
getKmsKeyNameBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for kmsKeyName.
-
getIpConfigurationValue
public int getIpConfigurationValue()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
- Specified by:
getIpConfigurationValue
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The enum numeric value on the wire for ipConfiguration.
-
getIpConfiguration
public WorkerIPAddressConfiguration getIpConfiguration()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;
- Specified by:
getIpConfiguration
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The ipConfiguration.
-
getWorkerRegion
public String getWorkerRegion()
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
string worker_region = 13;
- Specified by:
getWorkerRegion
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The workerRegion.
-
getWorkerRegionBytes
public com.google.protobuf.ByteString getWorkerRegionBytes()
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g. "us-west1". Mutually exclusive with worker_zone. If neither worker_region nor worker_zone is specified, default to the control plane's region.
string worker_region = 13;
- Specified by:
getWorkerRegionBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- 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 = 14;
- Specified by:
getWorkerZone
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The workerZone.
-
getWorkerZoneBytes
public com.google.protobuf.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 = 14;
- Specified by:
getWorkerZoneBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for workerZone.
-
getEnableStreamingEngine
public boolean getEnableStreamingEngine()
Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 15;
- Specified by:
getEnableStreamingEngine
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The enableStreamingEngine.
-
getFlexrsGoalValue
public int getFlexrsGoalValue()
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
- Specified by:
getFlexrsGoalValue
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The enum numeric value on the wire for flexrsGoal.
-
getFlexrsGoal
public FlexResourceSchedulingGoal getFlexrsGoal()
Set FlexRS goal for the job. https://cloud.google.com/dataflow/docs/guides/flexrs
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flexrs_goal = 16;
- Specified by:
getFlexrsGoal
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The flexrsGoal.
-
getStagingLocation
public String getStagingLocation()
The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;
- Specified by:
getStagingLocation
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The stagingLocation.
-
getStagingLocationBytes
public com.google.protobuf.ByteString getStagingLocationBytes()
The Cloud Storage path for staging local files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string staging_location = 17;
- Specified by:
getStagingLocationBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for stagingLocation.
-
getSdkContainerImage
public String getSdkContainerImage()
Docker registry location of container image to use for the 'worker harness. Default is the container for the version of the SDK. Note this field is only valid for portable pipelines.
string sdk_container_image = 18;
- Specified by:
getSdkContainerImage
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The sdkContainerImage.
-
getSdkContainerImageBytes
public com.google.protobuf.ByteString getSdkContainerImageBytes()
Docker registry location of container image to use for the 'worker harness. Default is the container for the version of the SDK. Note this field is only valid for portable pipelines.
string sdk_container_image = 18;
- Specified by:
getSdkContainerImageBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for sdkContainerImage.
-
getDiskSizeGb
public int getDiskSizeGb()
Worker disk size, in gigabytes.
int32 disk_size_gb = 20;
- Specified by:
getDiskSizeGb
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The diskSizeGb.
-
getAutoscalingAlgorithmValue
public int getAutoscalingAlgorithmValue()
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
- Specified by:
getAutoscalingAlgorithmValue
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The enum numeric value on the wire for autoscalingAlgorithm.
-
getAutoscalingAlgorithm
public AutoscalingAlgorithm getAutoscalingAlgorithm()
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;
- Specified by:
getAutoscalingAlgorithm
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The autoscalingAlgorithm.
-
getDumpHeapOnOom
public boolean getDumpHeapOnOom()
If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory. The location of the heap file will either be echoed back to the user, or the user will be given the opportunity to download the heap file.
bool dump_heap_on_oom = 22;
- Specified by:
getDumpHeapOnOom
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The dumpHeapOnOom.
-
getSaveHeapDumpsToGcsPath
public String getSaveHeapDumpsToGcsPath()
Cloud Storage bucket (directory) to upload heap dumps to the given location. Enabling this implies that heap dumps should be generated on OOM (dump_heap_on_oom is set to true).
string save_heap_dumps_to_gcs_path = 23;
- Specified by:
getSaveHeapDumpsToGcsPath
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The saveHeapDumpsToGcsPath.
-
getSaveHeapDumpsToGcsPathBytes
public com.google.protobuf.ByteString getSaveHeapDumpsToGcsPathBytes()
Cloud Storage bucket (directory) to upload heap dumps to the given location. Enabling this implies that heap dumps should be generated on OOM (dump_heap_on_oom is set to true).
string save_heap_dumps_to_gcs_path = 23;
- Specified by:
getSaveHeapDumpsToGcsPathBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for saveHeapDumpsToGcsPath.
-
getLauncherMachineType
public String getLauncherMachineType()
The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;
- Specified by:
getLauncherMachineType
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The launcherMachineType.
-
getLauncherMachineTypeBytes
public com.google.protobuf.ByteString getLauncherMachineTypeBytes()
The machine type to use for launching the job. The default is n1-standard-1.
string launcher_machine_type = 24;
- Specified by:
getLauncherMachineTypeBytes
in interfaceFlexTemplateRuntimeEnvironmentOrBuilder
- Returns:
- The bytes for launcherMachineType.
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static FlexTemplateRuntimeEnvironment parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static FlexTemplateRuntimeEnvironment parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static FlexTemplateRuntimeEnvironment parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public FlexTemplateRuntimeEnvironment.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static FlexTemplateRuntimeEnvironment.Builder newBuilder()
-
newBuilder
public static FlexTemplateRuntimeEnvironment.Builder newBuilder(FlexTemplateRuntimeEnvironment prototype)
-
toBuilder
public FlexTemplateRuntimeEnvironment.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected FlexTemplateRuntimeEnvironment.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static FlexTemplateRuntimeEnvironment getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment> parser()
-
getParserForType
public com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public FlexTemplateRuntimeEnvironment getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-