Class TaskGroup (0.41.0)

public final class TaskGroup extends GeneratedMessageV3 implements TaskGroupOrBuilder

A TaskGroup defines one or more Tasks that all share the same TaskSpec.

Protobuf type google.cloud.batch.v1alpha.TaskGroup

Implements

TaskGroupOrBuilder

Static Fields

ALLOCATION_POLICY_FIELD_NUMBER

public static final int ALLOCATION_POLICY_FIELD_NUMBER
Field Value
TypeDescription
int

LABELS_FIELD_NUMBER

public static final int LABELS_FIELD_NUMBER
Field Value
TypeDescription
int

NAME_FIELD_NUMBER

public static final int NAME_FIELD_NUMBER
Field Value
TypeDescription
int

PARALLELISM_FIELD_NUMBER

public static final int PARALLELISM_FIELD_NUMBER
Field Value
TypeDescription
int

PERMISSIVE_SSH_FIELD_NUMBER

public static final int PERMISSIVE_SSH_FIELD_NUMBER
Field Value
TypeDescription
int

REQUIRE_HOSTS_FILE_FIELD_NUMBER

public static final int REQUIRE_HOSTS_FILE_FIELD_NUMBER
Field Value
TypeDescription
int

RUN_AS_NON_ROOT_FIELD_NUMBER

public static final int RUN_AS_NON_ROOT_FIELD_NUMBER
Field Value
TypeDescription
int

SCHEDULING_POLICY_FIELD_NUMBER

public static final int SCHEDULING_POLICY_FIELD_NUMBER
Field Value
TypeDescription
int

TASK_COUNT_FIELD_NUMBER

public static final int TASK_COUNT_FIELD_NUMBER
Field Value
TypeDescription
int

TASK_COUNT_PER_NODE_FIELD_NUMBER

public static final int TASK_COUNT_PER_NODE_FIELD_NUMBER
Field Value
TypeDescription
int

TASK_ENVIRONMENTS_FIELD_NUMBER

public static final int TASK_ENVIRONMENTS_FIELD_NUMBER
Field Value
TypeDescription
int

TASK_SPEC_FIELD_NUMBER

public static final int TASK_SPEC_FIELD_NUMBER
Field Value
TypeDescription
int

Static Methods

getDefaultInstance()

public static TaskGroup getDefaultInstance()
Returns
TypeDescription
TaskGroup

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
TypeDescription
Descriptor

newBuilder()

public static TaskGroup.Builder newBuilder()
Returns
TypeDescription
TaskGroup.Builder

newBuilder(TaskGroup prototype)

public static TaskGroup.Builder newBuilder(TaskGroup prototype)
Parameter
NameDescription
prototypeTaskGroup
Returns
TypeDescription
TaskGroup.Builder

parseDelimitedFrom(InputStream input)

public static TaskGroup parseDelimitedFrom(InputStream input)
Parameter
NameDescription
inputInputStream
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
IOException

parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static TaskGroup parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
IOException

parseFrom(byte[] data)

public static TaskGroup parseFrom(byte[] data)
Parameter
NameDescription
databyte[]
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)

public static TaskGroup parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
databyte[]
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(ByteString data)

public static TaskGroup parseFrom(ByteString data)
Parameter
NameDescription
dataByteString
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)

public static TaskGroup parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
dataByteString
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(CodedInputStream input)

public static TaskGroup parseFrom(CodedInputStream input)
Parameter
NameDescription
inputCodedInputStream
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
IOException

parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public static TaskGroup parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputCodedInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
IOException

parseFrom(InputStream input)

public static TaskGroup parseFrom(InputStream input)
Parameter
NameDescription
inputInputStream
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
IOException

parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static TaskGroup parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
IOException

parseFrom(ByteBuffer data)

public static TaskGroup parseFrom(ByteBuffer data)
Parameter
NameDescription
dataByteBuffer
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)

public static TaskGroup parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
dataByteBuffer
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TaskGroup
Exceptions
TypeDescription
InvalidProtocolBufferException

parser()

public static Parser<TaskGroup> parser()
Returns
TypeDescription
Parser<TaskGroup>

Methods

containsLabels(String key)

public boolean containsLabels(String key)

Labels for the TaskGroup. Labels could be user provided or system generated. You can assign up to 64 labels. Google Compute Engine label restrictions apply. Label names that start with "goog-" or "google-" are reserved.

map<string, string> labels = 8;

Parameter
NameDescription
keyString
Returns
TypeDescription
boolean

equals(Object obj)

public boolean equals(Object obj)
Parameter
NameDescription
objObject
Returns
TypeDescription
boolean
Overrides

getAllocationPolicy()

public AllocationPolicy getAllocationPolicy()

Compute resource allocation for the TaskGroup. If specified, it overrides resources in Job.

.google.cloud.batch.v1alpha.AllocationPolicy allocation_policy = 7;

Returns
TypeDescription
AllocationPolicy

The allocationPolicy.

getAllocationPolicyOrBuilder()

public AllocationPolicyOrBuilder getAllocationPolicyOrBuilder()

Compute resource allocation for the TaskGroup. If specified, it overrides resources in Job.

.google.cloud.batch.v1alpha.AllocationPolicy allocation_policy = 7;

Returns
TypeDescription
AllocationPolicyOrBuilder

getDefaultInstanceForType()

public TaskGroup getDefaultInstanceForType()
Returns
TypeDescription
TaskGroup

getLabels() (deprecated)

public Map<String,String> getLabels()

Use #getLabelsMap() instead.

Returns
TypeDescription
Map<String,String>

getLabelsCount()

public int getLabelsCount()

Labels for the TaskGroup. Labels could be user provided or system generated. You can assign up to 64 labels. Google Compute Engine label restrictions apply. Label names that start with "goog-" or "google-" are reserved.

map<string, string> labels = 8;

Returns
TypeDescription
int

getLabelsMap()

public Map<String,String> getLabelsMap()

Labels for the TaskGroup. Labels could be user provided or system generated. You can assign up to 64 labels. Google Compute Engine label restrictions apply. Label names that start with "goog-" or "google-" are reserved.

map<string, string> labels = 8;

Returns
TypeDescription
Map<String,String>

getLabelsOrDefault(String key, String defaultValue)

public String getLabelsOrDefault(String key, String defaultValue)

Labels for the TaskGroup. Labels could be user provided or system generated. You can assign up to 64 labels. Google Compute Engine label restrictions apply. Label names that start with "goog-" or "google-" are reserved.

map<string, string> labels = 8;

Parameters
NameDescription
keyString
defaultValueString
Returns
TypeDescription
String

getLabelsOrThrow(String key)

public String getLabelsOrThrow(String key)

Labels for the TaskGroup. Labels could be user provided or system generated. You can assign up to 64 labels. Google Compute Engine label restrictions apply. Label names that start with "goog-" or "google-" are reserved.

map<string, string> labels = 8;

Parameter
NameDescription
keyString
Returns
TypeDescription
String

getName()

public String getName()

Output only. TaskGroup name. The system generates this field based on parent Job name. For example: "projects/123456/locations/us-west1/jobs/job01/taskGroups/group01".

string name = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];

Returns
TypeDescription
String

The name.

getNameBytes()

public ByteString getNameBytes()

Output only. TaskGroup name. The system generates this field based on parent Job name. For example: "projects/123456/locations/us-west1/jobs/job01/taskGroups/group01".

string name = 1 [(.google.api.field_behavior) = OUTPUT_ONLY];

Returns
TypeDescription
ByteString

The bytes for name.

getParallelism()

public long getParallelism()

Max number of tasks that can run in parallel. Default to min(task_count, parallel tasks per job limit). See: Job Limits. Field parallelism must be 1 if the scheduling_policy is IN_ORDER.

int64 parallelism = 5;

Returns
TypeDescription
long

The parallelism.

getParserForType()

public Parser<TaskGroup> getParserForType()
Returns
TypeDescription
Parser<TaskGroup>
Overrides

getPermissiveSsh()

public boolean getPermissiveSsh()

When true, Batch will configure SSH to allow passwordless login between VMs running the Batch tasks in the same TaskGroup.

bool permissive_ssh = 12;

Returns
TypeDescription
boolean

The permissiveSsh.

getRequireHostsFile()

public boolean getRequireHostsFile()

When true, Batch will populate a file with a list of all VMs assigned to the TaskGroup and set the BATCH_HOSTS_FILE environment variable to the path of that file. Defaults to false. The host file supports up to 1000 VMs.

bool require_hosts_file = 11;

Returns
TypeDescription
boolean

The requireHostsFile.

getRunAsNonRoot()

public boolean getRunAsNonRoot()

Optional. If not set or set to false, Batch uses the root user to execute runnables. If set to true, Batch runs the runnables using a non-root user. Currently, the non-root user Batch used is generated by OS Login. For more information, see About OS Login.

bool run_as_non_root = 14 [(.google.api.field_behavior) = OPTIONAL];

Returns
TypeDescription
boolean

The runAsNonRoot.

getSchedulingPolicy()

public TaskGroup.SchedulingPolicy getSchedulingPolicy()

Scheduling policy for Tasks in the TaskGroup. The default value is AS_SOON_AS_POSSIBLE.

.google.cloud.batch.v1alpha.TaskGroup.SchedulingPolicy scheduling_policy = 6;

Returns
TypeDescription
TaskGroup.SchedulingPolicy

The schedulingPolicy.

getSchedulingPolicyValue()

public int getSchedulingPolicyValue()

Scheduling policy for Tasks in the TaskGroup. The default value is AS_SOON_AS_POSSIBLE.

.google.cloud.batch.v1alpha.TaskGroup.SchedulingPolicy scheduling_policy = 6;

Returns
TypeDescription
int

The enum numeric value on the wire for schedulingPolicy.

getSerializedSize()

public int getSerializedSize()
Returns
TypeDescription
int
Overrides

getTaskCount()

public long getTaskCount()

Number of Tasks in the TaskGroup. Default is 1.

int64 task_count = 4;

Returns
TypeDescription
long

The taskCount.

getTaskCountPerNode()

public long getTaskCountPerNode()

Max number of tasks that can be run on a VM at the same time. If not specified, the system will decide a value based on available compute resources on a VM and task requirements.

int64 task_count_per_node = 10;

Returns
TypeDescription
long

The taskCountPerNode.

getTaskEnvironments(int index)

public Environment getTaskEnvironments(int index)

An array of environment variable mappings, which are passed to Tasks with matching indices. If task_environments is used then task_count should not be specified in the request (and will be ignored). Task count will be the length of task_environments.

Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in addition to any environment variables set in task_environments, specifying the number of Tasks in the Task's parent TaskGroup, and the specific Task's index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).

repeated .google.cloud.batch.v1alpha.Environment task_environments = 9;

Parameter
NameDescription
indexint
Returns
TypeDescription
Environment

getTaskEnvironmentsCount()

public int getTaskEnvironmentsCount()

An array of environment variable mappings, which are passed to Tasks with matching indices. If task_environments is used then task_count should not be specified in the request (and will be ignored). Task count will be the length of task_environments.

Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in addition to any environment variables set in task_environments, specifying the number of Tasks in the Task's parent TaskGroup, and the specific Task's index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).

repeated .google.cloud.batch.v1alpha.Environment task_environments = 9;

Returns
TypeDescription
int

getTaskEnvironmentsList()

public List<Environment> getTaskEnvironmentsList()

An array of environment variable mappings, which are passed to Tasks with matching indices. If task_environments is used then task_count should not be specified in the request (and will be ignored). Task count will be the length of task_environments.

Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in addition to any environment variables set in task_environments, specifying the number of Tasks in the Task's parent TaskGroup, and the specific Task's index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).

repeated .google.cloud.batch.v1alpha.Environment task_environments = 9;

Returns
TypeDescription
List<Environment>

getTaskEnvironmentsOrBuilder(int index)

public EnvironmentOrBuilder getTaskEnvironmentsOrBuilder(int index)

An array of environment variable mappings, which are passed to Tasks with matching indices. If task_environments is used then task_count should not be specified in the request (and will be ignored). Task count will be the length of task_environments.

Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in addition to any environment variables set in task_environments, specifying the number of Tasks in the Task's parent TaskGroup, and the specific Task's index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).

repeated .google.cloud.batch.v1alpha.Environment task_environments = 9;

Parameter
NameDescription
indexint
Returns
TypeDescription
EnvironmentOrBuilder

getTaskEnvironmentsOrBuilderList()

public List<? extends EnvironmentOrBuilder> getTaskEnvironmentsOrBuilderList()

An array of environment variable mappings, which are passed to Tasks with matching indices. If task_environments is used then task_count should not be specified in the request (and will be ignored). Task count will be the length of task_environments.

Tasks get a BATCH_TASK_INDEX and BATCH_TASK_COUNT environment variable, in addition to any environment variables set in task_environments, specifying the number of Tasks in the Task's parent TaskGroup, and the specific Task's index in the TaskGroup (0 through BATCH_TASK_COUNT - 1).

repeated .google.cloud.batch.v1alpha.Environment task_environments = 9;

Returns
TypeDescription
List<? extends com.google.cloud.batch.v1alpha.EnvironmentOrBuilder>

getTaskSpec()

public TaskSpec getTaskSpec()

Required. Tasks in the group share the same task spec.

.google.cloud.batch.v1alpha.TaskSpec task_spec = 3 [(.google.api.field_behavior) = REQUIRED];

Returns
TypeDescription
TaskSpec

The taskSpec.

getTaskSpecOrBuilder()

public TaskSpecOrBuilder getTaskSpecOrBuilder()

Required. Tasks in the group share the same task spec.

.google.cloud.batch.v1alpha.TaskSpec task_spec = 3 [(.google.api.field_behavior) = REQUIRED];

Returns
TypeDescription
TaskSpecOrBuilder

hasAllocationPolicy()

public boolean hasAllocationPolicy()

Compute resource allocation for the TaskGroup. If specified, it overrides resources in Job.

.google.cloud.batch.v1alpha.AllocationPolicy allocation_policy = 7;

Returns
TypeDescription
boolean

Whether the allocationPolicy field is set.

hasTaskSpec()

public boolean hasTaskSpec()

Required. Tasks in the group share the same task spec.

.google.cloud.batch.v1alpha.TaskSpec task_spec = 3 [(.google.api.field_behavior) = REQUIRED];

Returns
TypeDescription
boolean

Whether the taskSpec field is set.

hashCode()

public int hashCode()
Returns
TypeDescription
int
Overrides

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
TypeDescription
FieldAccessorTable
Overrides

internalGetMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
Parameter
NameDescription
numberint
Returns
TypeDescription
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)

isInitialized()

public final boolean isInitialized()
Returns
TypeDescription
boolean
Overrides

newBuilderForType()

public TaskGroup.Builder newBuilderForType()
Returns
TypeDescription
TaskGroup.Builder

newBuilderForType(GeneratedMessageV3.BuilderParent parent)

protected TaskGroup.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
NameDescription
parentBuilderParent
Returns
TypeDescription
TaskGroup.Builder
Overrides

newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
NameDescription
unusedUnusedPrivateParameter
Returns
TypeDescription
Object
Overrides

toBuilder()

public TaskGroup.Builder toBuilder()
Returns
TypeDescription
TaskGroup.Builder

writeTo(CodedOutputStream output)

public void writeTo(CodedOutputStream output)
Parameter
NameDescription
outputCodedOutputStream
Overrides
Exceptions
TypeDescription
IOException