Package com.google.dataflow.v1beta3
Class Environment
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- 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
public final class Environment extends com.google.protobuf.GeneratedMessageV3 implements EnvironmentOrBuilder
Describes the environment in which a Dataflow Job runs.
Protobuf typegoogle.dataflow.v1beta3.Environment- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classEnvironment.BuilderDescribes the environment in which a Dataflow Job runs.-
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 intCLUSTER_MANAGER_API_SERVICE_FIELD_NUMBERstatic intDATASET_FIELD_NUMBERstatic intDEBUG_OPTIONS_FIELD_NUMBERstatic intEXPERIMENTS_FIELD_NUMBERstatic intFLEX_RESOURCE_SCHEDULING_GOAL_FIELD_NUMBERstatic intINTERNAL_EXPERIMENTS_FIELD_NUMBERstatic intSDK_PIPELINE_OPTIONS_FIELD_NUMBERstatic intSERVICE_ACCOUNT_EMAIL_FIELD_NUMBERstatic intSERVICE_KMS_KEY_NAME_FIELD_NUMBERstatic intSERVICE_OPTIONS_FIELD_NUMBERstatic intSHUFFLE_MODE_FIELD_NUMBERstatic intTEMP_STORAGE_PREFIX_FIELD_NUMBERstatic intUSER_AGENT_FIELD_NUMBERstatic intVERSION_FIELD_NUMBERstatic intWORKER_POOLS_FIELD_NUMBERstatic intWORKER_REGION_FIELD_NUMBERstatic intWORKER_ZONE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)StringgetClusterManagerApiService()The type of cluster manager API to use.com.google.protobuf.ByteStringgetClusterManagerApiServiceBytes()The type of cluster manager API to use.StringgetDataset()The dataset for the current project where various workflow related tables are stored.com.google.protobuf.ByteStringgetDatasetBytes()The dataset for the current project where various workflow related tables are stored.DebugOptionsgetDebugOptions()Any debugging options to be supplied to the job.DebugOptionsOrBuildergetDebugOptionsOrBuilder()Any debugging options to be supplied to the job.static EnvironmentgetDefaultInstance()EnvironmentgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()StringgetExperiments(int index)The list of experiments to enable.com.google.protobuf.ByteStringgetExperimentsBytes(int index)The list of experiments to enable.intgetExperimentsCount()The list of experiments to enable.com.google.protobuf.ProtocolStringListgetExperimentsList()The list of experiments to enable.FlexResourceSchedulingGoalgetFlexResourceSchedulingGoal()Which Flexible Resource Scheduling mode to run in.intgetFlexResourceSchedulingGoalValue()Which Flexible Resource Scheduling mode to run in.com.google.protobuf.AnygetInternalExperiments()Experimental settings.com.google.protobuf.AnyOrBuildergetInternalExperimentsOrBuilder()Experimental settings.com.google.protobuf.Parser<Environment>getParserForType()com.google.protobuf.StructgetSdkPipelineOptions()The Cloud Dataflow SDK pipeline options specified by the user.com.google.protobuf.StructOrBuildergetSdkPipelineOptionsOrBuilder()The Cloud Dataflow SDK pipeline options specified by the user.intgetSerializedSize()StringgetServiceAccountEmail()Identity to run virtual machines as.com.google.protobuf.ByteStringgetServiceAccountEmailBytes()Identity to run virtual machines as.StringgetServiceKmsKeyName()If set, contains the Cloud KMS key identifier used to encrypt data at rest, AKA a Customer Managed Encryption Key (CMEK).com.google.protobuf.ByteStringgetServiceKmsKeyNameBytes()If set, contains the Cloud KMS key identifier used to encrypt data at rest, AKA a Customer Managed Encryption Key (CMEK).StringgetServiceOptions(int index)The list of service options to enable.com.google.protobuf.ByteStringgetServiceOptionsBytes(int index)The list of service options to enable.intgetServiceOptionsCount()The list of service options to enable.com.google.protobuf.ProtocolStringListgetServiceOptionsList()The list of service options to enable.ShuffleModegetShuffleMode()Output only.intgetShuffleModeValue()Output only.StringgetTempStoragePrefix()The prefix of the resources the system should use for temporary storage.com.google.protobuf.ByteStringgetTempStoragePrefixBytes()The prefix of the resources the system should use for temporary storage.com.google.protobuf.StructgetUserAgent()A description of the process that generated the request.com.google.protobuf.StructOrBuildergetUserAgentOrBuilder()A description of the process that generated the request.com.google.protobuf.StructgetVersion()A structure describing which components and their versions of the service are required in order to run the job.com.google.protobuf.StructOrBuildergetVersionOrBuilder()A structure describing which components and their versions of the service are required in order to run the job.WorkerPoolgetWorkerPools(int index)The worker pools.intgetWorkerPoolsCount()The worker pools.List<WorkerPool>getWorkerPoolsList()The worker pools.WorkerPoolOrBuildergetWorkerPoolsOrBuilder(int index)The worker pools.List<? extends WorkerPoolOrBuilder>getWorkerPoolsOrBuilderList()The worker pools.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.booleanhasDebugOptions()Any debugging options to be supplied to the job.inthashCode()booleanhasInternalExperiments()Experimental settings.booleanhasSdkPipelineOptions()The Cloud Dataflow SDK pipeline options specified by the user.booleanhasUserAgent()A description of the process that generated the request.booleanhasVersion()A structure describing which components and their versions of the service are required in order to run the job.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static Environment.BuildernewBuilder()static Environment.BuildernewBuilder(Environment prototype)Environment.BuildernewBuilderForType()protected Environment.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static EnvironmentparseDelimitedFrom(InputStream input)static EnvironmentparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static EnvironmentparseFrom(byte[] data)static EnvironmentparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static EnvironmentparseFrom(com.google.protobuf.ByteString data)static EnvironmentparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static EnvironmentparseFrom(com.google.protobuf.CodedInputStream input)static EnvironmentparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static EnvironmentparseFrom(InputStream input)static EnvironmentparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static EnvironmentparseFrom(ByteBuffer data)static EnvironmentparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<Environment>parser()Environment.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, internalGetMapField, 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
-
TEMP_STORAGE_PREFIX_FIELD_NUMBER
public static final int TEMP_STORAGE_PREFIX_FIELD_NUMBER
- See Also:
- Constant Field Values
-
CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER
public static final int CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
EXPERIMENTS_FIELD_NUMBER
public static final int EXPERIMENTS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SERVICE_OPTIONS_FIELD_NUMBER
public static final int SERVICE_OPTIONS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SERVICE_KMS_KEY_NAME_FIELD_NUMBER
public static final int SERVICE_KMS_KEY_NAME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
WORKER_POOLS_FIELD_NUMBER
public static final int WORKER_POOLS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
USER_AGENT_FIELD_NUMBER
public static final int USER_AGENT_FIELD_NUMBER
- See Also:
- Constant Field Values
-
VERSION_FIELD_NUMBER
public static final int VERSION_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DATASET_FIELD_NUMBER
public static final int DATASET_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SDK_PIPELINE_OPTIONS_FIELD_NUMBER
public static final int SDK_PIPELINE_OPTIONS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
INTERNAL_EXPERIMENTS_FIELD_NUMBER
public static final int INTERNAL_EXPERIMENTS_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
-
FLEX_RESOURCE_SCHEDULING_GOAL_FIELD_NUMBER
public static final int FLEX_RESOURCE_SCHEDULING_GOAL_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
-
SHUFFLE_MODE_FIELD_NUMBER
public static final int SHUFFLE_MODE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DEBUG_OPTIONS_FIELD_NUMBER
public static final int DEBUG_OPTIONS_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()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3
-
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:
getTempStoragePrefixin interfaceEnvironmentOrBuilder- 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:
getTempStoragePrefixBytesin interfaceEnvironmentOrBuilder- 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:
getClusterManagerApiServicein interfaceEnvironmentOrBuilder- 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:
getClusterManagerApiServiceBytesin interfaceEnvironmentOrBuilder- 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:
getExperimentsListin interfaceEnvironmentOrBuilder- 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:
getExperimentsCountin interfaceEnvironmentOrBuilder- 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:
getExperimentsin interfaceEnvironmentOrBuilder- 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:
getExperimentsBytesin interfaceEnvironmentOrBuilder- 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()
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;- Specified by:
getServiceOptionsListin interfaceEnvironmentOrBuilder- Returns:
- A list containing the serviceOptions.
-
getServiceOptionsCount
public int getServiceOptionsCount()
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;- Specified by:
getServiceOptionsCountin interfaceEnvironmentOrBuilder- Returns:
- The count of serviceOptions.
-
getServiceOptions
public String getServiceOptions(int index)
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;- Specified by:
getServiceOptionsin interfaceEnvironmentOrBuilder- 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)
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;- Specified by:
getServiceOptionsBytesin interfaceEnvironmentOrBuilder- Parameters:
index- The index of the value to return.- Returns:
- The bytes of the serviceOptions at the given index.
-
getServiceKmsKeyName
public String getServiceKmsKeyName()
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;- Specified by:
getServiceKmsKeyNamein interfaceEnvironmentOrBuilder- Returns:
- The serviceKmsKeyName.
-
getServiceKmsKeyNameBytes
public com.google.protobuf.ByteString getServiceKmsKeyNameBytes()
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;- Specified by:
getServiceKmsKeyNameBytesin interfaceEnvironmentOrBuilder- 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:
getWorkerPoolsListin interfaceEnvironmentOrBuilder
-
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:
getWorkerPoolsOrBuilderListin interfaceEnvironmentOrBuilder
-
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:
getWorkerPoolsCountin interfaceEnvironmentOrBuilder
-
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:
getWorkerPoolsin interfaceEnvironmentOrBuilder
-
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:
getWorkerPoolsOrBuilderin interfaceEnvironmentOrBuilder
-
hasUserAgent
public boolean hasUserAgent()
A description of the process that generated the request.
.google.protobuf.Struct user_agent = 5;- Specified by:
hasUserAgentin interfaceEnvironmentOrBuilder- Returns:
- Whether the userAgent field is set.
-
getUserAgent
public com.google.protobuf.Struct getUserAgent()
A description of the process that generated the request.
.google.protobuf.Struct user_agent = 5;- Specified by:
getUserAgentin interfaceEnvironmentOrBuilder- Returns:
- The userAgent.
-
getUserAgentOrBuilder
public com.google.protobuf.StructOrBuilder getUserAgentOrBuilder()
A description of the process that generated the request.
.google.protobuf.Struct user_agent = 5;- Specified by:
getUserAgentOrBuilderin interfaceEnvironmentOrBuilder
-
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:
hasVersionin interfaceEnvironmentOrBuilder- 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:
getVersionin interfaceEnvironmentOrBuilder- 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:
getVersionOrBuilderin interfaceEnvironmentOrBuilder
-
getDataset
public String getDataset()
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;- Specified by:
getDatasetin interfaceEnvironmentOrBuilder- Returns:
- The dataset.
-
getDatasetBytes
public com.google.protobuf.ByteString getDatasetBytes()
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;- Specified by:
getDatasetBytesin interfaceEnvironmentOrBuilder- 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:
hasSdkPipelineOptionsin interfaceEnvironmentOrBuilder- 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:
getSdkPipelineOptionsin interfaceEnvironmentOrBuilder- 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:
getSdkPipelineOptionsOrBuilderin interfaceEnvironmentOrBuilder
-
hasInternalExperiments
public boolean hasInternalExperiments()
Experimental settings.
.google.protobuf.Any internal_experiments = 9;- Specified by:
hasInternalExperimentsin interfaceEnvironmentOrBuilder- Returns:
- Whether the internalExperiments field is set.
-
getInternalExperiments
public com.google.protobuf.Any getInternalExperiments()
Experimental settings.
.google.protobuf.Any internal_experiments = 9;- Specified by:
getInternalExperimentsin interfaceEnvironmentOrBuilder- Returns:
- The internalExperiments.
-
getInternalExperimentsOrBuilder
public com.google.protobuf.AnyOrBuilder getInternalExperimentsOrBuilder()
Experimental settings.
.google.protobuf.Any internal_experiments = 9;- Specified by:
getInternalExperimentsOrBuilderin interfaceEnvironmentOrBuilder
-
getServiceAccountEmail
public String getServiceAccountEmail()
Identity to run virtual machines as. Defaults to the default account.
string service_account_email = 10;- Specified by:
getServiceAccountEmailin interfaceEnvironmentOrBuilder- Returns:
- The serviceAccountEmail.
-
getServiceAccountEmailBytes
public com.google.protobuf.ByteString getServiceAccountEmailBytes()
Identity to run virtual machines as. Defaults to the default account.
string service_account_email = 10;- Specified by:
getServiceAccountEmailBytesin interfaceEnvironmentOrBuilder- Returns:
- The bytes for serviceAccountEmail.
-
getFlexResourceSchedulingGoalValue
public int getFlexResourceSchedulingGoalValue()
Which Flexible Resource Scheduling mode to run in.
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;- Specified by:
getFlexResourceSchedulingGoalValuein interfaceEnvironmentOrBuilder- Returns:
- The enum numeric value on the wire for flexResourceSchedulingGoal.
-
getFlexResourceSchedulingGoal
public FlexResourceSchedulingGoal getFlexResourceSchedulingGoal()
Which Flexible Resource Scheduling mode to run in.
.google.dataflow.v1beta3.FlexResourceSchedulingGoal flex_resource_scheduling_goal = 11;- Specified by:
getFlexResourceSchedulingGoalin interfaceEnvironmentOrBuilder- Returns:
- The flexResourceSchedulingGoal.
-
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 interfaceEnvironmentOrBuilder- 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 interfaceEnvironmentOrBuilder- 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.
string worker_zone = 14;- Specified by:
getWorkerZonein interfaceEnvironmentOrBuilder- 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.
string worker_zone = 14;- Specified by:
getWorkerZoneBytesin interfaceEnvironmentOrBuilder- 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:
getShuffleModeValuein interfaceEnvironmentOrBuilder- 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:
getShuffleModein interfaceEnvironmentOrBuilder- Returns:
- The shuffleMode.
-
hasDebugOptions
public boolean hasDebugOptions()
Any debugging options to be supplied to the job.
.google.dataflow.v1beta3.DebugOptions debug_options = 17;- Specified by:
hasDebugOptionsin interfaceEnvironmentOrBuilder- Returns:
- Whether the debugOptions field is set.
-
getDebugOptions
public DebugOptions getDebugOptions()
Any debugging options to be supplied to the job.
.google.dataflow.v1beta3.DebugOptions debug_options = 17;- Specified by:
getDebugOptionsin interfaceEnvironmentOrBuilder- Returns:
- The debugOptions.
-
getDebugOptionsOrBuilder
public DebugOptionsOrBuilder getDebugOptionsOrBuilder()
Any debugging options to be supplied to the job.
.google.dataflow.v1beta3.DebugOptions debug_options = 17;- Specified by:
getDebugOptionsOrBuilderin interfaceEnvironmentOrBuilder
-
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 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:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static Environment.Builder newBuilder()
-
newBuilder
public static Environment.Builder newBuilder(Environment prototype)
-
toBuilder
public Environment.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected Environment.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static Environment getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<Environment> parser()
-
getParserForType
public com.google.protobuf.Parser<Environment> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public Environment getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-