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 class
Environment.Builder
Describes 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 int
CLUSTER_MANAGER_API_SERVICE_FIELD_NUMBER
static int
DATASET_FIELD_NUMBER
static int
DEBUG_OPTIONS_FIELD_NUMBER
static int
EXPERIMENTS_FIELD_NUMBER
static int
FLEX_RESOURCE_SCHEDULING_GOAL_FIELD_NUMBER
static int
INTERNAL_EXPERIMENTS_FIELD_NUMBER
static int
SDK_PIPELINE_OPTIONS_FIELD_NUMBER
static int
SERVICE_ACCOUNT_EMAIL_FIELD_NUMBER
static int
SERVICE_KMS_KEY_NAME_FIELD_NUMBER
static int
SERVICE_OPTIONS_FIELD_NUMBER
static int
SHUFFLE_MODE_FIELD_NUMBER
static int
TEMP_STORAGE_PREFIX_FIELD_NUMBER
static int
USER_AGENT_FIELD_NUMBER
static int
VERSION_FIELD_NUMBER
static int
WORKER_POOLS_FIELD_NUMBER
static int
WORKER_REGION_FIELD_NUMBER
static int
WORKER_ZONE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
String
getClusterManagerApiService()
The type of cluster manager API to use.com.google.protobuf.ByteString
getClusterManagerApiServiceBytes()
The type of cluster manager API to use.String
getDataset()
The dataset for the current project where various workflow related tables are stored.com.google.protobuf.ByteString
getDatasetBytes()
The dataset for the current project where various workflow related tables are stored.DebugOptions
getDebugOptions()
Any debugging options to be supplied to the job.DebugOptionsOrBuilder
getDebugOptionsOrBuilder()
Any debugging options to be supplied to the job.static Environment
getDefaultInstance()
Environment
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
String
getExperiments(int index)
The list of experiments to enable.com.google.protobuf.ByteString
getExperimentsBytes(int index)
The list of experiments to enable.int
getExperimentsCount()
The list of experiments to enable.com.google.protobuf.ProtocolStringList
getExperimentsList()
The list of experiments to enable.FlexResourceSchedulingGoal
getFlexResourceSchedulingGoal()
Which Flexible Resource Scheduling mode to run in.int
getFlexResourceSchedulingGoalValue()
Which Flexible Resource Scheduling mode to run in.com.google.protobuf.Any
getInternalExperiments()
Experimental settings.com.google.protobuf.AnyOrBuilder
getInternalExperimentsOrBuilder()
Experimental settings.com.google.protobuf.Parser<Environment>
getParserForType()
com.google.protobuf.Struct
getSdkPipelineOptions()
The Cloud Dataflow SDK pipeline options specified by the user.com.google.protobuf.StructOrBuilder
getSdkPipelineOptionsOrBuilder()
The Cloud Dataflow SDK pipeline options specified by the user.int
getSerializedSize()
String
getServiceAccountEmail()
Identity to run virtual machines as.com.google.protobuf.ByteString
getServiceAccountEmailBytes()
Identity to run virtual machines as.String
getServiceKmsKeyName()
If set, contains the Cloud KMS key identifier used to encrypt data at rest, AKA a Customer Managed Encryption Key (CMEK).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).String
getServiceOptions(int index)
The list of service options to enable.com.google.protobuf.ByteString
getServiceOptionsBytes(int index)
The list of service options to enable.int
getServiceOptionsCount()
The list of service options to enable.com.google.protobuf.ProtocolStringList
getServiceOptionsList()
The list of service options to enable.ShuffleMode
getShuffleMode()
Output only.int
getShuffleModeValue()
Output only.String
getTempStoragePrefix()
The prefix of the resources the system should use for temporary storage.com.google.protobuf.ByteString
getTempStoragePrefixBytes()
The prefix of the resources the system should use for temporary storage.com.google.protobuf.Struct
getUserAgent()
A description of the process that generated the request.com.google.protobuf.StructOrBuilder
getUserAgentOrBuilder()
A description of the process that generated the request.com.google.protobuf.Struct
getVersion()
A structure describing which components and their versions of the service are required in order to run the job.com.google.protobuf.StructOrBuilder
getVersionOrBuilder()
A structure describing which components and their versions of the service are required in order to run the job.WorkerPool
getWorkerPools(int index)
The worker pools.int
getWorkerPoolsCount()
The worker pools.List<WorkerPool>
getWorkerPoolsList()
The worker pools.WorkerPoolOrBuilder
getWorkerPoolsOrBuilder(int index)
The worker pools.List<? extends WorkerPoolOrBuilder>
getWorkerPoolsOrBuilderList()
The worker pools.String
getWorkerRegion()
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.com.google.protobuf.ByteString
getWorkerRegionBytes()
The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.String
getWorkerZone()
The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.com.google.protobuf.ByteString
getWorkerZoneBytes()
The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.boolean
hasDebugOptions()
Any debugging options to be supplied to the job.int
hashCode()
boolean
hasInternalExperiments()
Experimental settings.boolean
hasSdkPipelineOptions()
The Cloud Dataflow SDK pipeline options specified by the user.boolean
hasUserAgent()
A description of the process that generated the request.boolean
hasVersion()
A structure describing which components and their versions of the service are required in order to run the job.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static Environment.Builder
newBuilder()
static Environment.Builder
newBuilder(Environment prototype)
Environment.Builder
newBuilderForType()
protected Environment.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static Environment
parseDelimitedFrom(InputStream input)
static Environment
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Environment
parseFrom(byte[] data)
static Environment
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Environment
parseFrom(com.google.protobuf.ByteString data)
static Environment
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Environment
parseFrom(com.google.protobuf.CodedInputStream input)
static Environment
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Environment
parseFrom(InputStream input)
static Environment
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Environment
parseFrom(ByteBuffer data)
static Environment
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<Environment>
parser()
Environment.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, 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:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in 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:
getTempStoragePrefix
in 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:
getTempStoragePrefixBytes
in 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:
getClusterManagerApiService
in 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:
getClusterManagerApiServiceBytes
in 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:
getExperimentsList
in 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:
getExperimentsCount
in 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:
getExperiments
in 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:
getExperimentsBytes
in 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:
getServiceOptionsList
in 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:
getServiceOptionsCount
in 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:
getServiceOptions
in 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:
getServiceOptionsBytes
in 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:
getServiceKmsKeyName
in 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:
getServiceKmsKeyNameBytes
in 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:
getWorkerPoolsList
in 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:
getWorkerPoolsOrBuilderList
in 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:
getWorkerPoolsCount
in 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:
getWorkerPools
in 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:
getWorkerPoolsOrBuilder
in interfaceEnvironmentOrBuilder
-
hasUserAgent
public boolean hasUserAgent()
A description of the process that generated the request.
.google.protobuf.Struct user_agent = 5;
- Specified by:
hasUserAgent
in 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:
getUserAgent
in 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:
getUserAgentOrBuilder
in 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:
hasVersion
in 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:
getVersion
in 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:
getVersionOrBuilder
in 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:
getDataset
in 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:
getDatasetBytes
in 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:
hasSdkPipelineOptions
in 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:
getSdkPipelineOptions
in 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:
getSdkPipelineOptionsOrBuilder
in interfaceEnvironmentOrBuilder
-
hasInternalExperiments
public boolean hasInternalExperiments()
Experimental settings.
.google.protobuf.Any internal_experiments = 9;
- Specified by:
hasInternalExperiments
in 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:
getInternalExperiments
in interfaceEnvironmentOrBuilder
- Returns:
- The internalExperiments.
-
getInternalExperimentsOrBuilder
public com.google.protobuf.AnyOrBuilder getInternalExperimentsOrBuilder()
Experimental settings.
.google.protobuf.Any internal_experiments = 9;
- Specified by:
getInternalExperimentsOrBuilder
in interfaceEnvironmentOrBuilder
-
getServiceAccountEmail
public String getServiceAccountEmail()
Identity to run virtual machines as. Defaults to the default account.
string service_account_email = 10;
- Specified by:
getServiceAccountEmail
in 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:
getServiceAccountEmailBytes
in 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:
getFlexResourceSchedulingGoalValue
in 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:
getFlexResourceSchedulingGoal
in 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:
getWorkerRegion
in 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:
getWorkerRegionBytes
in 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:
getWorkerZone
in 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:
getWorkerZoneBytes
in 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:
getShuffleModeValue
in 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:
getShuffleMode
in 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:
hasDebugOptions
in 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:
getDebugOptions
in 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:
getDebugOptionsOrBuilder
in interfaceEnvironmentOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static 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 interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in 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:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected Environment.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in 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:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public Environment getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-