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 classFlexTemplateRuntimeEnvironment.BuilderThe 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 intADDITIONAL_EXPERIMENTS_FIELD_NUMBERstatic intADDITIONAL_USER_LABELS_FIELD_NUMBERstatic intAUTOSCALING_ALGORITHM_FIELD_NUMBERstatic intDISK_SIZE_GB_FIELD_NUMBERstatic intDUMP_HEAP_ON_OOM_FIELD_NUMBERstatic intENABLE_STREAMING_ENGINE_FIELD_NUMBERstatic intFLEXRS_GOAL_FIELD_NUMBERstatic intIP_CONFIGURATION_FIELD_NUMBERstatic intKMS_KEY_NAME_FIELD_NUMBERstatic intLAUNCHER_MACHINE_TYPE_FIELD_NUMBERstatic intMACHINE_TYPE_FIELD_NUMBERstatic intMAX_WORKERS_FIELD_NUMBERstatic intNETWORK_FIELD_NUMBERstatic intNUM_WORKERS_FIELD_NUMBERstatic intSAVE_HEAP_DUMPS_TO_GCS_PATH_FIELD_NUMBERstatic intSDK_CONTAINER_IMAGE_FIELD_NUMBERstatic intSERVICE_ACCOUNT_EMAIL_FIELD_NUMBERstatic intSTAGING_LOCATION_FIELD_NUMBERstatic intSUBNETWORK_FIELD_NUMBERstatic intTEMP_LOCATION_FIELD_NUMBERstatic intWORKER_REGION_FIELD_NUMBERstatic intWORKER_ZONE_FIELD_NUMBERstatic intZONE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description booleancontainsAdditionalUserLabels(String key)Additional user labels to be specified for the job.booleanequals(Object obj)StringgetAdditionalExperiments(int index)Additional experiment flags for the job.com.google.protobuf.ByteStringgetAdditionalExperimentsBytes(int index)Additional experiment flags for the job.intgetAdditionalExperimentsCount()Additional experiment flags for the job.com.google.protobuf.ProtocolStringListgetAdditionalExperimentsList()Additional experiment flags for the job.Map<String,String>getAdditionalUserLabels()Deprecated.intgetAdditionalUserLabelsCount()Additional user labels to be specified for the job.Map<String,String>getAdditionalUserLabelsMap()Additional user labels to be specified for the job.StringgetAdditionalUserLabelsOrDefault(String key, String defaultValue)Additional user labels to be specified for the job.StringgetAdditionalUserLabelsOrThrow(String key)Additional user labels to be specified for the job.AutoscalingAlgorithmgetAutoscalingAlgorithm()The algorithm to use for autoscalingintgetAutoscalingAlgorithmValue()The algorithm to use for autoscalingstatic FlexTemplateRuntimeEnvironmentgetDefaultInstance()FlexTemplateRuntimeEnvironmentgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()intgetDiskSizeGb()Worker disk size, in gigabytes.booleangetDumpHeapOnOom()If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory.booleangetEnableStreamingEngine()Whether to enable Streaming Engine for the job.FlexResourceSchedulingGoalgetFlexrsGoal()Set FlexRS goal for the job.intgetFlexrsGoalValue()Set FlexRS goal for the job.WorkerIPAddressConfigurationgetIpConfiguration()Configuration for VM IPs.intgetIpConfigurationValue()Configuration for VM IPs.StringgetKmsKeyName()Name for the Cloud KMS key for the job.com.google.protobuf.ByteStringgetKmsKeyNameBytes()Name for the Cloud KMS key for the job.StringgetLauncherMachineType()The machine type to use for launching the job.com.google.protobuf.ByteStringgetLauncherMachineTypeBytes()The machine type to use for launching the job.StringgetMachineType()The machine type to use for the job.com.google.protobuf.ByteStringgetMachineTypeBytes()The machine type to use for the job.intgetMaxWorkers()The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.StringgetNetwork()Network to which VMs will be assigned.com.google.protobuf.ByteStringgetNetworkBytes()Network to which VMs will be assigned.intgetNumWorkers()The initial number of Google Compute Engine instances for the job.com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment>getParserForType()StringgetSaveHeapDumpsToGcsPath()Cloud Storage bucket (directory) to upload heap dumps to the given location.com.google.protobuf.ByteStringgetSaveHeapDumpsToGcsPathBytes()Cloud Storage bucket (directory) to upload heap dumps to the given location.StringgetSdkContainerImage()Docker registry location of container image to use for the 'worker harness.com.google.protobuf.ByteStringgetSdkContainerImageBytes()Docker registry location of container image to use for the 'worker harness.intgetSerializedSize()StringgetServiceAccountEmail()The email address of the service account to run the job as.com.google.protobuf.ByteStringgetServiceAccountEmailBytes()The email address of the service account to run the job as.StringgetStagingLocation()The Cloud Storage path for staging local files.com.google.protobuf.ByteStringgetStagingLocationBytes()The Cloud Storage path for staging local files.StringgetSubnetwork()Subnetwork to which VMs will be assigned, if desired.com.google.protobuf.ByteStringgetSubnetworkBytes()Subnetwork to which VMs will be assigned, if desired.StringgetTempLocation()The Cloud Storage path to use for temporary files.com.google.protobuf.ByteStringgetTempLocationBytes()The Cloud Storage path to use for temporary files.StringgetWorkerRegion()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.ByteStringgetWorkerRegionBytes()The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.StringgetWorkerZone()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.ByteStringgetWorkerZoneBytes()The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.StringgetZone()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.ByteStringgetZoneBytes()The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.inthashCode()protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()protected com.google.protobuf.MapFieldinternalGetMapField(int number)booleanisInitialized()static FlexTemplateRuntimeEnvironment.BuildernewBuilder()static FlexTemplateRuntimeEnvironment.BuildernewBuilder(FlexTemplateRuntimeEnvironment prototype)FlexTemplateRuntimeEnvironment.BuildernewBuilderForType()protected FlexTemplateRuntimeEnvironment.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static FlexTemplateRuntimeEnvironmentparseDelimitedFrom(InputStream input)static FlexTemplateRuntimeEnvironmentparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlexTemplateRuntimeEnvironmentparseFrom(byte[] data)static FlexTemplateRuntimeEnvironmentparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlexTemplateRuntimeEnvironmentparseFrom(com.google.protobuf.ByteString data)static FlexTemplateRuntimeEnvironmentparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlexTemplateRuntimeEnvironmentparseFrom(com.google.protobuf.CodedInputStream input)static FlexTemplateRuntimeEnvironmentparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlexTemplateRuntimeEnvironmentparseFrom(InputStream input)static FlexTemplateRuntimeEnvironmentparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static FlexTemplateRuntimeEnvironmentparseFrom(ByteBuffer data)static FlexTemplateRuntimeEnvironmentparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<FlexTemplateRuntimeEnvironment>parser()FlexTemplateRuntimeEnvironment.BuildertoBuilder()voidwriteTo(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:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetMapField
protected com.google.protobuf.MapField internalGetMapField(int number)
- Overrides:
internalGetMapFieldin classcom.google.protobuf.GeneratedMessageV3
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein 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:
getNumWorkersin 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:
getMaxWorkersin 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:
getZonein 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:
getZoneBytesin 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:
getServiceAccountEmailin 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:
getServiceAccountEmailBytesin 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:
getTempLocationin 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:
getTempLocationBytesin 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:
getMachineTypein 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:
getMachineTypeBytesin 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:
getAdditionalExperimentsListin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- A list containing the additionalExperiments.
-
getAdditionalExperimentsCount
public int getAdditionalExperimentsCount()
Additional experiment flags for the job.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsCountin 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:
getAdditionalExperimentsin 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:
getAdditionalExperimentsBytesin 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:
getNetworkin 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:
getNetworkBytesin 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:
getSubnetworkin 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:
getSubnetworkBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for subnetwork.
-
getAdditionalUserLabelsCount
public int getAdditionalUserLabelsCount()
Description copied from interface:FlexTemplateRuntimeEnvironmentOrBuilderAdditional 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:
getAdditionalUserLabelsCountin 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:
containsAdditionalUserLabelsin interfaceFlexTemplateRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabels
@Deprecated public Map<String,String> getAdditionalUserLabels()
Deprecated.UsegetAdditionalUserLabelsMap()instead.- Specified by:
getAdditionalUserLabelsin 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:
getAdditionalUserLabelsMapin 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:
getAdditionalUserLabelsOrDefaultin 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:
getAdditionalUserLabelsOrThrowin 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:
getKmsKeyNamein 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:
getKmsKeyNameBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for kmsKeyName.
-
getIpConfigurationValue
public int getIpConfigurationValue()
Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 12;- Specified by:
getIpConfigurationValuein 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:
getIpConfigurationin 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:
getWorkerRegionin 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:
getWorkerRegionBytesin 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:
getWorkerZonein 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:
getWorkerZoneBytesin 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:
getEnableStreamingEnginein 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:
getFlexrsGoalValuein 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:
getFlexrsGoalin 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:
getStagingLocationin 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:
getStagingLocationBytesin 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:
getSdkContainerImagein 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:
getSdkContainerImageBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for sdkContainerImage.
-
getDiskSizeGb
public int getDiskSizeGb()
Worker disk size, in gigabytes.
int32 disk_size_gb = 20;- Specified by:
getDiskSizeGbin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The diskSizeGb.
-
getAutoscalingAlgorithmValue
public int getAutoscalingAlgorithmValue()
The algorithm to use for autoscaling
.google.dataflow.v1beta3.AutoscalingAlgorithm autoscaling_algorithm = 21;- Specified by:
getAutoscalingAlgorithmValuein 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:
getAutoscalingAlgorithmin 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:
getDumpHeapOnOomin 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:
getSaveHeapDumpsToGcsPathin 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:
getSaveHeapDumpsToGcsPathBytesin 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:
getLauncherMachineTypein 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:
getLauncherMachineTypeBytesin interfaceFlexTemplateRuntimeEnvironmentOrBuilder- Returns:
- The bytes for launcherMachineType.
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein 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:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein 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:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected FlexTemplateRuntimeEnvironment.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein 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:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public FlexTemplateRuntimeEnvironment getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-