Package com.google.dataflow.v1beta3
Class RuntimeEnvironment
java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
com.google.dataflow.v1beta3.RuntimeEnvironment
- All Implemented Interfaces:
RuntimeEnvironmentOrBuilder,com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable
@Generated
public final class RuntimeEnvironment
extends com.google.protobuf.GeneratedMessage
implements RuntimeEnvironmentOrBuilder
The environment values to set at runtime.Protobuf type
google.dataflow.v1beta3.RuntimeEnvironment- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classThe environment values to set at runtime.Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT, BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message, T extends Object>, com.google.protobuf.GeneratedMessage.UnusedPrivateParameter Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessage
com.google.protobuf.AbstractMessage.BuilderParentNested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessageLite.InternalOneOfEnum -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intFields inherited from class com.google.protobuf.GeneratedMessage
alwaysUseFieldBuilders, loggedPre22TypeNames, unknownFieldsFields inherited from class com.google.protobuf.AbstractMessage
memoizedSizeFields inherited from class com.google.protobuf.AbstractMessageLite
memoizedHashCode -
Method Summary
Modifier and TypeMethodDescriptionbooleanOptional.booleangetAdditionalExperiments(int index) Optional.com.google.protobuf.ByteStringgetAdditionalExperimentsBytes(int index) Optional.intOptional.com.google.protobuf.ProtocolStringListOptional.getAdditionalPipelineOptions(int index) Optional.com.google.protobuf.ByteStringgetAdditionalPipelineOptionsBytes(int index) Optional.intOptional.com.google.protobuf.ProtocolStringListOptional.Deprecated.intOptional.Optional.getAdditionalUserLabelsOrDefault(String key, String defaultValue) Optional.Optional.booleanOptional.static RuntimeEnvironmentstatic final com.google.protobuf.Descriptors.DescriptorintOptional.booleanOptional.Optional.intOptional.Optional.com.google.protobuf.ByteStringOptional.Optional.com.google.protobuf.ByteStringOptional.intOptional.Optional.com.google.protobuf.ByteStringOptional.intOptional.com.google.protobuf.Parser<RuntimeEnvironment>intOptional.com.google.protobuf.ByteStringOptional.Optional.intOptional.Optional.com.google.protobuf.ByteStringOptional.Required.com.google.protobuf.ByteStringRequired.Required.com.google.protobuf.ByteStringRequired.Optional.com.google.protobuf.ByteStringOptional.getZone()Optional.com.google.protobuf.ByteStringOptional.inthashCode()booleanOptional.protected com.google.protobuf.GeneratedMessage.FieldAccessorTableprotected com.google.protobuf.MapFieldReflectionAccessorinternalGetMapFieldReflection(int number) final booleanstatic RuntimeEnvironment.Builderstatic RuntimeEnvironment.BuildernewBuilder(RuntimeEnvironment prototype) protected RuntimeEnvironment.BuildernewBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) static RuntimeEnvironmentparseDelimitedFrom(InputStream input) static RuntimeEnvironmentparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static RuntimeEnvironmentparseFrom(byte[] data) static RuntimeEnvironmentparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static RuntimeEnvironmentparseFrom(com.google.protobuf.ByteString data) static RuntimeEnvironmentparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static RuntimeEnvironmentparseFrom(com.google.protobuf.CodedInputStream input) static RuntimeEnvironmentparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static RuntimeEnvironmentparseFrom(InputStream input) static RuntimeEnvironmentparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static RuntimeEnvironmentparseFrom(ByteBuffer data) static RuntimeEnvironmentparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static com.google.protobuf.Parser<RuntimeEnvironment>parser()voidwriteTo(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessage
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, newFileScopedGeneratedExtension, newInstance, newMessageScopedGeneratedExtension, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTagMethods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashFields, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite
addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Field Details
-
NUM_WORKERS_FIELD_NUMBER
public static final int NUM_WORKERS_FIELD_NUMBER- See Also:
-
MAX_WORKERS_FIELD_NUMBER
public static final int MAX_WORKERS_FIELD_NUMBER- See Also:
-
ZONE_FIELD_NUMBER
public static final int ZONE_FIELD_NUMBER- See Also:
-
SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER- See Also:
-
TEMP_LOCATION_FIELD_NUMBER
public static final int TEMP_LOCATION_FIELD_NUMBER- See Also:
-
BYPASS_TEMP_DIR_VALIDATION_FIELD_NUMBER
public static final int BYPASS_TEMP_DIR_VALIDATION_FIELD_NUMBER- See Also:
-
MACHINE_TYPE_FIELD_NUMBER
public static final int MACHINE_TYPE_FIELD_NUMBER- See Also:
-
ADDITIONAL_EXPERIMENTS_FIELD_NUMBER
public static final int ADDITIONAL_EXPERIMENTS_FIELD_NUMBER- See Also:
-
NETWORK_FIELD_NUMBER
public static final int NETWORK_FIELD_NUMBER- See Also:
-
SUBNETWORK_FIELD_NUMBER
public static final int SUBNETWORK_FIELD_NUMBER- See Also:
-
ADDITIONAL_USER_LABELS_FIELD_NUMBER
public static final int ADDITIONAL_USER_LABELS_FIELD_NUMBER- See Also:
-
KMS_KEY_NAME_FIELD_NUMBER
public static final int KMS_KEY_NAME_FIELD_NUMBER- See Also:
-
IP_CONFIGURATION_FIELD_NUMBER
public static final int IP_CONFIGURATION_FIELD_NUMBER- See Also:
-
WORKER_REGION_FIELD_NUMBER
public static final int WORKER_REGION_FIELD_NUMBER- See Also:
-
WORKER_ZONE_FIELD_NUMBER
public static final int WORKER_ZONE_FIELD_NUMBER- See Also:
-
ENABLE_STREAMING_ENGINE_FIELD_NUMBER
public static final int ENABLE_STREAMING_ENGINE_FIELD_NUMBER- See Also:
-
DISK_SIZE_GB_FIELD_NUMBER
public static final int DISK_SIZE_GB_FIELD_NUMBER- See Also:
-
STREAMING_MODE_FIELD_NUMBER
public static final int STREAMING_MODE_FIELD_NUMBER- See Also:
-
ADDITIONAL_PIPELINE_OPTIONS_FIELD_NUMBER
public static final int ADDITIONAL_PIPELINE_OPTIONS_FIELD_NUMBER- See Also:
-
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
internalGetMapFieldReflection
protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number) - Overrides:
internalGetMapFieldReflectionin classcom.google.protobuf.GeneratedMessage
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessage
-
getNumWorkers
public int getNumWorkers()Optional. The initial number of Google Compute Engine instances for the job. The default value is 11.
int32 num_workers = 11;- Specified by:
getNumWorkersin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The numWorkers.
-
getMaxWorkers
public int getMaxWorkers()Optional. The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000. The default value is 1.
int32 max_workers = 1;- Specified by:
getMaxWorkersin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The maxWorkers.
-
getZone
Optional. 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 = 2;- Specified by:
getZonein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The zone.
-
getZoneBytes
public com.google.protobuf.ByteString getZoneBytes()Optional. 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 = 2;- Specified by:
getZoneBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for zone.
-
getServiceAccountEmail
Optional. The email address of the service account to run the job as.
string service_account_email = 3;- Specified by:
getServiceAccountEmailin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The serviceAccountEmail.
-
getServiceAccountEmailBytes
public com.google.protobuf.ByteString getServiceAccountEmailBytes()Optional. The email address of the service account to run the job as.
string service_account_email = 3;- Specified by:
getServiceAccountEmailBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for serviceAccountEmail.
-
getTempLocation
Required. The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 4;- Specified by:
getTempLocationin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The tempLocation.
-
getTempLocationBytes
public com.google.protobuf.ByteString getTempLocationBytes()Required. The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with `gs://`.
string temp_location = 4;- Specified by:
getTempLocationBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for tempLocation.
-
getBypassTempDirValidation
public boolean getBypassTempDirValidation()Optional. Whether to bypass the safety checks for the job's temporary directory. Use with caution.
bool bypass_temp_dir_validation = 5;- Specified by:
getBypassTempDirValidationin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bypassTempDirValidation.
-
getMachineType
Optional. 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 interfaceRuntimeEnvironmentOrBuilder- Returns:
- The machineType.
-
getMachineTypeBytes
public com.google.protobuf.ByteString getMachineTypeBytes()Optional. 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 interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for machineType.
-
getAdditionalExperimentsList
public com.google.protobuf.ProtocolStringList getAdditionalExperimentsList()Optional. Additional experiment flags for the job, specified with the `--experiments` option.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsListin interfaceRuntimeEnvironmentOrBuilder- Returns:
- A list containing the additionalExperiments.
-
getAdditionalExperimentsCount
public int getAdditionalExperimentsCount()Optional. Additional experiment flags for the job, specified with the `--experiments` option.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsCountin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The count of additionalExperiments.
-
getAdditionalExperiments
Optional. Additional experiment flags for the job, specified with the `--experiments` option.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsin interfaceRuntimeEnvironmentOrBuilder- 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) Optional. Additional experiment flags for the job, specified with the `--experiments` option.
repeated string additional_experiments = 7;- Specified by:
getAdditionalExperimentsBytesin interfaceRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the value to return.- Returns:
- The bytes of the additionalExperiments at the given index.
-
getNetwork
Optional. Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Specified by:
getNetworkin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The network.
-
getNetworkBytes
public com.google.protobuf.ByteString getNetworkBytes()Optional. Network to which VMs will be assigned. If empty or unspecified, the service will use the network "default".
string network = 8;- Specified by:
getNetworkBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for network.
-
getSubnetwork
Optional. 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 interfaceRuntimeEnvironmentOrBuilder- Returns:
- The subnetwork.
-
getSubnetworkBytes
public com.google.protobuf.ByteString getSubnetworkBytes()Optional. 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 interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for subnetwork.
-
getAdditionalUserLabelsCount
public int getAdditionalUserLabelsCount()Description copied from interface:RuntimeEnvironmentOrBuilderOptional. Additional user labels to be specified for the job. Keys and values should 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 interfaceRuntimeEnvironmentOrBuilder
-
containsAdditionalUserLabels
Optional. Additional user labels to be specified for the job. Keys and values should 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 interfaceRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabels
Deprecated.UsegetAdditionalUserLabelsMap()instead.- Specified by:
getAdditionalUserLabelsin interfaceRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsMap
Optional. Additional user labels to be specified for the job. Keys and values should 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 interfaceRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsOrDefault
Optional. Additional user labels to be specified for the job. Keys and values should 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 interfaceRuntimeEnvironmentOrBuilder
-
getAdditionalUserLabelsOrThrow
Optional. Additional user labels to be specified for the job. Keys and values should 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 interfaceRuntimeEnvironmentOrBuilder
-
getKmsKeyName
Optional. 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;- Specified by:
getKmsKeyNamein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The kmsKeyName.
-
getKmsKeyNameBytes
public com.google.protobuf.ByteString getKmsKeyNameBytes()Optional. 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;- Specified by:
getKmsKeyNameBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for kmsKeyName.
-
getIpConfigurationValue
public int getIpConfigurationValue()Optional. Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;- Specified by:
getIpConfigurationValuein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for ipConfiguration.
-
getIpConfiguration
Optional. Configuration for VM IPs.
.google.dataflow.v1beta3.WorkerIPAddressConfiguration ip_configuration = 14;- Specified by:
getIpConfigurationin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The ipConfiguration.
-
getWorkerRegion
Required. 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 = 15;- Specified by:
getWorkerRegionin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The workerRegion.
-
getWorkerRegionBytes
public com.google.protobuf.ByteString getWorkerRegionBytes()Required. 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 = 15;- Specified by:
getWorkerRegionBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for workerRegion.
-
getWorkerZone
Optional. 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;- Specified by:
getWorkerZonein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The workerZone.
-
getWorkerZoneBytes
public com.google.protobuf.ByteString getWorkerZoneBytes()Optional. 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;- Specified by:
getWorkerZoneBytesin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The bytes for workerZone.
-
getEnableStreamingEngine
public boolean getEnableStreamingEngine()Optional. Whether to enable Streaming Engine for the job.
bool enable_streaming_engine = 17;- Specified by:
getEnableStreamingEnginein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The enableStreamingEngine.
-
getDiskSizeGb
public int getDiskSizeGb()Optional. The disk size, in gigabytes, to use on each remote Compute Engine worker instance.
int32 disk_size_gb = 18;- Specified by:
getDiskSizeGbin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The diskSizeGb.
-
hasStreamingMode
public boolean hasStreamingMode()Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
hasStreamingModein interfaceRuntimeEnvironmentOrBuilder- Returns:
- Whether the streamingMode field is set.
-
getStreamingModeValue
public int getStreamingModeValue()Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getStreamingModeValuein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for streamingMode.
-
getStreamingMode
Optional. Specifies the Streaming Engine message processing guarantees. Reduces cost and latency but might result in duplicate messages committed to storage. Designed to run simple mapping streaming ETL jobs at the lowest cost. For example, Change Data Capture (CDC) to BigQuery is a canonical use case. For more information, see [Set the pipeline streaming mode](https://cloud.google.com/dataflow/docs/guides/streaming-modes).
optional .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getStreamingModein interfaceRuntimeEnvironmentOrBuilder- Returns:
- The streamingMode.
-
getAdditionalPipelineOptionsList
public com.google.protobuf.ProtocolStringList getAdditionalPipelineOptionsList()Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 20 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsListin interfaceRuntimeEnvironmentOrBuilder- Returns:
- A list containing the additionalPipelineOptions.
-
getAdditionalPipelineOptionsCount
public int getAdditionalPipelineOptionsCount()Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 20 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsCountin interfaceRuntimeEnvironmentOrBuilder- Returns:
- The count of additionalPipelineOptions.
-
getAdditionalPipelineOptions
Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 20 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsin interfaceRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The additionalPipelineOptions at the given index.
-
getAdditionalPipelineOptionsBytes
public com.google.protobuf.ByteString getAdditionalPipelineOptionsBytes(int index) Optional. Additional pipeline option flags for the job.
repeated string additional_pipeline_options = 20 [(.google.api.field_behavior) = OPTIONAL];- Specified by:
getAdditionalPipelineOptionsBytesin interfaceRuntimeEnvironmentOrBuilder- Parameters:
index- The index of the value to return.- Returns:
- The bytes of the additionalPipelineOptions at the given index.
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
- 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 RuntimeEnvironment parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static RuntimeEnvironment parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static RuntimeEnvironment parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static RuntimeEnvironment parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static RuntimeEnvironment parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static RuntimeEnvironment parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
- Throws:
IOException
-
parseFrom
public static RuntimeEnvironment parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseDelimitedFrom
- Throws:
IOException
-
parseDelimitedFrom
public static RuntimeEnvironment parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseFrom
public static RuntimeEnvironment parseFrom(com.google.protobuf.CodedInputStream input) throws IOException - Throws:
IOException
-
parseFrom
public static RuntimeEnvironment parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
newBuilderForType
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
-
toBuilder
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected RuntimeEnvironment.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) - Overrides:
newBuilderForTypein classcom.google.protobuf.AbstractMessage
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-