Package com.google.dataflow.v1beta3

Class Environment

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
com.google.dataflow.v1beta3.Environment
All Implemented Interfaces:
EnvironmentOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable
@Generated public final class Environment extends com.google.protobuf.GeneratedMessage implements EnvironmentOrBuilder
 Describes the environment in which a Dataflow Job runs.
Protobuf type google.dataflow.v1beta3.Environment
See Also:

  • Field Details

    • TEMP_STORAGE_PREFIX_FIELD_NUMBER

      public static final int TEMP_STORAGE_PREFIX_FIELD_NUMBER
      See Also:

    • CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER

      public static final int CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER
      See Also:

    • EXPERIMENTS_FIELD_NUMBER

      public static final int EXPERIMENTS_FIELD_NUMBER
      See Also:

    • SERVICE_OPTIONS_FIELD_NUMBER

      public static final int SERVICE_OPTIONS_FIELD_NUMBER
      See Also:

    • SERVICE_KMS_KEY_NAME_FIELD_NUMBER

      public static final int SERVICE_KMS_KEY_NAME_FIELD_NUMBER
      See Also:

    • WORKER_POOLS_FIELD_NUMBER

      public static final int WORKER_POOLS_FIELD_NUMBER
      See Also:

    • USER_AGENT_FIELD_NUMBER

      public static final int USER_AGENT_FIELD_NUMBER
      See Also:

    • VERSION_FIELD_NUMBER

      public static final int VERSION_FIELD_NUMBER
      See Also:

    • DATASET_FIELD_NUMBER

      public static final int DATASET_FIELD_NUMBER
      See Also:

    • SDK_PIPELINE_OPTIONS_FIELD_NUMBER

      public static final int SDK_PIPELINE_OPTIONS_FIELD_NUMBER
      See Also:

    • INTERNAL_EXPERIMENTS_FIELD_NUMBER

      public static final int INTERNAL_EXPERIMENTS_FIELD_NUMBER
      See Also:

    • SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER

      public static final int SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
      See Also:

    • FLEX_RESOURCE_SCHEDULING_GOAL_FIELD_NUMBER

      public static final int FLEX_RESOURCE_SCHEDULING_GOAL_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:

    • SHUFFLE_MODE_FIELD_NUMBER

      public static final int SHUFFLE_MODE_FIELD_NUMBER
      See Also:

    • DEBUG_OPTIONS_FIELD_NUMBER

      public static final int DEBUG_OPTIONS_FIELD_NUMBER
      See Also:

    • USE_STREAMING_ENGINE_RESOURCE_BASED_BILLING_FIELD_NUMBER

      public static final int USE_STREAMING_ENGINE_RESOURCE_BASED_BILLING_FIELD_NUMBER
      See Also:

    • STREAMING_MODE_FIELD_NUMBER

      public static final int STREAMING_MODE_FIELD_NUMBER
      See Also:

    • USE_PUBLIC_IPS_FIELD_NUMBER

      public static final int USE_PUBLIC_IPS_FIELD_NUMBER
      See Also:

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

    • getTempStoragePrefix

      public String getTempStoragePrefix()
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Specified by:
      getTempStoragePrefix in interface EnvironmentOrBuilder
      Returns:
      The tempStoragePrefix.

    • getTempStoragePrefixBytes

      public com.google.protobuf.ByteString getTempStoragePrefixBytes()
       The prefix of the resources the system should use for temporary
 storage.  The system will append the suffix "/temp-{JOBNAME} to
 this resource prefix, where {JOBNAME} is the value of the
 job_name field.  The resulting bucket and object prefix is used
 as the prefix of the resources used to store temporary data
 needed during the job execution.  NOTE: This will override the
 value in taskrunner_settings.
 The supported resource type is:

 Google Cloud Storage:

 storage.googleapis.com/{bucket}/{object}
 bucket.storage.googleapis.com/{object}
      string temp_storage_prefix = 1;
      Specified by:
      getTempStoragePrefixBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for tempStoragePrefix.

    • getClusterManagerApiService

      public String getClusterManagerApiService()
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Specified by:
      getClusterManagerApiService in interface EnvironmentOrBuilder
      Returns:
      The clusterManagerApiService.

    • getClusterManagerApiServiceBytes

      public com.google.protobuf.ByteString getClusterManagerApiServiceBytes()
       The type of cluster manager API to use.  If unknown or
 unspecified, the service will attempt to choose a reasonable
 default.  This should be in the form of the API service name,
 e.g. "compute.googleapis.com".
      string cluster_manager_api_service = 2;
      Specified by:
      getClusterManagerApiServiceBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for clusterManagerApiService.

    • getExperimentsList

      public com.google.protobuf.ProtocolStringList getExperimentsList()
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperimentsList in interface EnvironmentOrBuilder
      Returns:
      A list containing the experiments.

    • getExperimentsCount

      public int getExperimentsCount()
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperimentsCount in interface EnvironmentOrBuilder
      Returns:
      The count of experiments.

    • getExperiments

      public String getExperiments(int index)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperiments in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The experiments at the given index.

    • getExperimentsBytes

      public com.google.protobuf.ByteString getExperimentsBytes(int index)
       The list of experiments to enable. This field should be used for SDK
 related experiments and not for service related experiments. The proper
 field for service related experiments is service_options.
      repeated string experiments = 3;
      Specified by:
      getExperimentsBytes in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the experiments at the given index.

    • getServiceOptionsList

      public com.google.protobuf.ProtocolStringList getServiceOptionsList()
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptionsList in interface EnvironmentOrBuilder
      Returns:
      A list containing the serviceOptions.

    • getServiceOptionsCount

      public int getServiceOptionsCount()
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptionsCount in interface EnvironmentOrBuilder
      Returns:
      The count of serviceOptions.

    • getServiceOptions

      public String getServiceOptions(int index)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptions in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The serviceOptions at the given index.

    • getServiceOptionsBytes

      public com.google.protobuf.ByteString getServiceOptionsBytes(int index)
       Optional. The list of service options to enable. This field should be used
 for service related experiments only. These experiments, when graduating to
 GA, should be replaced by dedicated fields or become default (i.e. always
 on).
      repeated string service_options = 16 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceOptionsBytes in interface EnvironmentOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the serviceOptions at the given index.

    • getServiceKmsKeyName

      public String getServiceKmsKeyName()
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceKmsKeyName in interface EnvironmentOrBuilder
      Returns:
      The serviceKmsKeyName.

    • getServiceKmsKeyNameBytes

      public com.google.protobuf.ByteString getServiceKmsKeyNameBytes()
       Optional. If set, contains the Cloud KMS key identifier used to encrypt
 data at rest, AKA a Customer Managed Encryption Key (CMEK).

 Format:
 projects/PROJECT_ID/locations/LOCATION/keyRings/KEY_RING/cryptoKeys/KEY
      string service_kms_key_name = 12 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceKmsKeyNameBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for serviceKmsKeyName.

    • getWorkerPoolsList

      public List<WorkerPool> getWorkerPoolsList()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsList in interface EnvironmentOrBuilder

    • getWorkerPoolsOrBuilderList

      public List<? extends WorkerPoolOrBuilder> getWorkerPoolsOrBuilderList()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsOrBuilderList in interface EnvironmentOrBuilder

    • getWorkerPoolsCount

      public int getWorkerPoolsCount()
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsCount in interface EnvironmentOrBuilder

    • getWorkerPools

      public WorkerPool getWorkerPools(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPools in interface EnvironmentOrBuilder

    • getWorkerPoolsOrBuilder

      public WorkerPoolOrBuilder getWorkerPoolsOrBuilder(int index)
       The worker pools. At least one "harness" worker pool must be
 specified in order for the job to have workers.
      repeated .google.dataflow.v1beta3.WorkerPool worker_pools = 4;
      Specified by:
      getWorkerPoolsOrBuilder in interface EnvironmentOrBuilder

    • hasUserAgent

      public boolean hasUserAgent()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasUserAgent in interface EnvironmentOrBuilder
      Returns:
      Whether the userAgent field is set.

    • getUserAgent

      public com.google.protobuf.Struct getUserAgent()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getUserAgent in interface EnvironmentOrBuilder
      Returns:
      The userAgent.

    • getUserAgentOrBuilder

      public com.google.protobuf.StructOrBuilder getUserAgentOrBuilder()
       Optional. A description of the process that generated the request.
      .google.protobuf.Struct user_agent = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getUserAgentOrBuilder in interface EnvironmentOrBuilder

    • hasVersion

      public boolean hasVersion()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;
      Specified by:
      hasVersion in interface EnvironmentOrBuilder
      Returns:
      Whether the version field is set.

    • getVersion

      public com.google.protobuf.Struct getVersion()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;
      Specified by:
      getVersion in interface EnvironmentOrBuilder
      Returns:
      The version.

    • getVersionOrBuilder

      public com.google.protobuf.StructOrBuilder getVersionOrBuilder()
       A structure describing which components and their versions of the service
 are required in order to run the job.
      .google.protobuf.Struct version = 6;
      Specified by:
      getVersionOrBuilder in interface EnvironmentOrBuilder

    • getDataset

      public String getDataset()
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDataset in interface EnvironmentOrBuilder
      Returns:
      The dataset.

    • getDatasetBytes

      public com.google.protobuf.ByteString getDatasetBytes()
       Optional. The dataset for the current project where various workflow
 related tables are stored.

 The supported resource type is:

 Google BigQuery:
 bigquery.googleapis.com/{dataset}
      string dataset = 7 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDatasetBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for dataset.

    • hasSdkPipelineOptions

      public boolean hasSdkPipelineOptions()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;
      Specified by:
      hasSdkPipelineOptions in interface EnvironmentOrBuilder
      Returns:
      Whether the sdkPipelineOptions field is set.

    • getSdkPipelineOptions

      public com.google.protobuf.Struct getSdkPipelineOptions()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;
      Specified by:
      getSdkPipelineOptions in interface EnvironmentOrBuilder
      Returns:
      The sdkPipelineOptions.

    • getSdkPipelineOptionsOrBuilder

      public com.google.protobuf.StructOrBuilder getSdkPipelineOptionsOrBuilder()
       The Cloud Dataflow SDK pipeline options specified by the user. These
 options are passed through the service and are used to recreate the
 SDK pipeline options on the worker in a language agnostic and platform
 independent way.
      .google.protobuf.Struct sdk_pipeline_options = 8;
      Specified by:
      getSdkPipelineOptionsOrBuilder in interface EnvironmentOrBuilder

    • hasInternalExperiments

      public boolean hasInternalExperiments()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;
      Specified by:
      hasInternalExperiments in interface EnvironmentOrBuilder
      Returns:
      Whether the internalExperiments field is set.

    • getInternalExperiments

      public com.google.protobuf.Any getInternalExperiments()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;
      Specified by:
      getInternalExperiments in interface EnvironmentOrBuilder
      Returns:
      The internalExperiments.

    • getInternalExperimentsOrBuilder

      public com.google.protobuf.AnyOrBuilder getInternalExperimentsOrBuilder()
       Experimental settings.
      .google.protobuf.Any internal_experiments = 9;
      Specified by:
      getInternalExperimentsOrBuilder in interface EnvironmentOrBuilder

    • getServiceAccountEmail

      public String getServiceAccountEmail()
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceAccountEmail in interface EnvironmentOrBuilder
      Returns:
      The serviceAccountEmail.

    • getServiceAccountEmailBytes

      public com.google.protobuf.ByteString getServiceAccountEmailBytes()
       Optional. Identity to run virtual machines as. Defaults to the default
 account.
      string service_account_email = 10 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getServiceAccountEmailBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for serviceAccountEmail.

    • getFlexResourceSchedulingGoalValue

      public int getFlexResourceSchedulingGoalValue()
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getFlexResourceSchedulingGoalValue in interface EnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for flexResourceSchedulingGoal.

    • getFlexResourceSchedulingGoal

      public FlexResourceSchedulingGoal getFlexResourceSchedulingGoal()
       Optional. Which Flexible Resource Scheduling mode to run in.
      .google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getFlexResourceSchedulingGoal in interface EnvironmentOrBuilder
      Returns:
      The flexResourceSchedulingGoal.

    • getWorkerRegion

      public String getWorkerRegion()
       Optional. 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 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerRegion in interface EnvironmentOrBuilder
      Returns:
      The workerRegion.

    • getWorkerRegionBytes

      public com.google.protobuf.ByteString getWorkerRegionBytes()
       Optional. 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 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerRegionBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for workerRegion.

    • getWorkerZone

      public String 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.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerZone in interface EnvironmentOrBuilder
      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.
      string worker_zone = 14 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getWorkerZoneBytes in interface EnvironmentOrBuilder
      Returns:
      The bytes for workerZone.

    • getShuffleModeValue

      public int getShuffleModeValue()
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getShuffleModeValue in interface EnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for shuffleMode.

    • getShuffleMode

      public ShuffleMode getShuffleMode()
       Output only. The shuffle mode used for the job.
      .google.dataflow.v1beta3.ShuffleMode shuffle_mode = 15 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getShuffleMode in interface EnvironmentOrBuilder
      Returns:
      The shuffleMode.

    • hasDebugOptions

      public boolean hasDebugOptions()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasDebugOptions in interface EnvironmentOrBuilder
      Returns:
      Whether the debugOptions field is set.

    • getDebugOptions

      public DebugOptions getDebugOptions()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDebugOptions in interface EnvironmentOrBuilder
      Returns:
      The debugOptions.

    • getDebugOptionsOrBuilder

      public DebugOptionsOrBuilder getDebugOptionsOrBuilder()
       Optional. Any debugging options to be supplied to the job.
      .google.dataflow.v1beta3.DebugOptions debug_options = 17 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getDebugOptionsOrBuilder in interface EnvironmentOrBuilder

    • getUseStreamingEngineResourceBasedBilling

      public boolean getUseStreamingEngineResourceBasedBilling()
       Output only. Whether the job uses the Streaming Engine resource-based
 billing model.
      bool use_streaming_engine_resource_based_billing = 18 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getUseStreamingEngineResourceBasedBilling in interface EnvironmentOrBuilder
      Returns:
      The useStreamingEngineResourceBasedBilling.

    • 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).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getStreamingModeValue in interface EnvironmentOrBuilder
      Returns:
      The enum numeric value on the wire for streamingMode.

    • getStreamingMode

      public 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).
      .google.dataflow.v1beta3.StreamingMode streaming_mode = 19 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getStreamingMode in interface EnvironmentOrBuilder
      Returns:
      The streamingMode.

    • getUsePublicIps

      public boolean getUsePublicIps()
       Optional. True when any worker pool that uses public IPs is present.
      bool use_public_ips = 20 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getUsePublicIps in interface EnvironmentOrBuilder
      Returns:
      The usePublicIps.

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage

    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage

    • parseFrom

      public static Environment parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static Environment parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static Environment parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static Environment parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static Environment parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static Environment parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static Environment parseFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static Environment parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static Environment parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static Environment parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseFrom

      public static Environment parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static Environment parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • newBuilderForType

      public Environment.Builder newBuilderForType()
      Specified by:
      newBuilderForType in interface com.google.protobuf.Message
      Specified by:
      newBuilderForType in interface com.google.protobuf.MessageLite

    • newBuilder

      public static Environment.Builder newBuilder()

    • newBuilder

      public static Environment.Builder newBuilder(Environment prototype)

    • toBuilder

      public Environment.Builder toBuilder()
      Specified by:
      toBuilder in interface com.google.protobuf.Message
      Specified by:
      toBuilder in interface com.google.protobuf.MessageLite

    • newBuilderForType

      protected Environment.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • getDefaultInstance

      public static Environment getDefaultInstance()

    • parser

      public static com.google.protobuf.Parser<Environment> parser()

    • getParserForType

      public com.google.protobuf.Parser<Environment> getParserForType()
      Specified by:
      getParserForType in interface com.google.protobuf.Message
      Specified by:
      getParserForType in interface com.google.protobuf.MessageLite
      Overrides:
      getParserForType in class com.google.protobuf.GeneratedMessage

    • getDefaultInstanceForType

      public Environment getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder