public final class Job extends GeneratedMessageV3 implements JobOrBuilder
A Cloud Dataproc job resource.Protobuf type
google.cloud.dataproc.v1.Job
Modifier and Type | Class and Description |
---|---|
static class |
Job.Builder
A Cloud Dataproc job resource.
|
static class |
Job.TypeJobCase |
GeneratedMessageV3.BuilderParent, GeneratedMessageV3.ExtendableBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage,BuilderType extends GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, GeneratedMessageV3.ExtendableMessage<MessageType extends GeneratedMessageV3.ExtendableMessage>, GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage>, GeneratedMessageV3.FieldAccessorTable
Modifier and Type | Field and Description |
---|---|
static int |
DRIVER_CONTROL_FILES_URI_FIELD_NUMBER |
static int |
DRIVER_OUTPUT_RESOURCE_URI_FIELD_NUMBER |
static int |
HADOOP_JOB_FIELD_NUMBER |
static int |
HIVE_JOB_FIELD_NUMBER |
static int |
LABELS_FIELD_NUMBER |
static int |
PIG_JOB_FIELD_NUMBER |
static int |
PLACEMENT_FIELD_NUMBER |
static int |
PYSPARK_JOB_FIELD_NUMBER |
static int |
REFERENCE_FIELD_NUMBER |
static int |
SCHEDULING_FIELD_NUMBER |
static int |
SPARK_JOB_FIELD_NUMBER |
static int |
SPARK_SQL_JOB_FIELD_NUMBER |
static int |
STATUS_FIELD_NUMBER |
static int |
STATUS_HISTORY_FIELD_NUMBER |
static int |
YARN_APPLICATIONS_FIELD_NUMBER |
alwaysUseFieldBuilders, unknownFields
memoizedSize
memoizedHashCode
canUseUnsafe, computeStringSize, computeStringSizeNoTag, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, makeExtensionsImmutable, newBuilderForType, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int REFERENCE_FIELD_NUMBER
public static final int PLACEMENT_FIELD_NUMBER
public static final int HADOOP_JOB_FIELD_NUMBER
public static final int SPARK_JOB_FIELD_NUMBER
public static final int PYSPARK_JOB_FIELD_NUMBER
public static final int HIVE_JOB_FIELD_NUMBER
public static final int PIG_JOB_FIELD_NUMBER
public static final int SPARK_SQL_JOB_FIELD_NUMBER
public static final int STATUS_FIELD_NUMBER
public static final int STATUS_HISTORY_FIELD_NUMBER
public static final int YARN_APPLICATIONS_FIELD_NUMBER
public static final int DRIVER_OUTPUT_RESOURCE_URI_FIELD_NUMBER
public static final int DRIVER_CONTROL_FILES_URI_FIELD_NUMBER
public static final int LABELS_FIELD_NUMBER
public static final int SCHEDULING_FIELD_NUMBER
public final UnknownFieldSet getUnknownFields()
getUnknownFields
in interface MessageOrBuilder
getUnknownFields
in class GeneratedMessageV3
public static final Descriptors.Descriptor getDescriptor()
protected MapField internalGetMapField(int number)
internalGetMapField
in class GeneratedMessageV3
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class GeneratedMessageV3
public Job.TypeJobCase getTypeJobCase()
getTypeJobCase
in interface JobOrBuilder
public boolean hasReference()
Optional. The fully qualified reference to the job, which can be used to obtain the equivalent REST path of the job resource. If this property is not specified when a job is created, the server generates a <code>job_id</code>.
.google.cloud.dataproc.v1.JobReference reference = 1;
hasReference
in interface JobOrBuilder
public JobReference getReference()
Optional. The fully qualified reference to the job, which can be used to obtain the equivalent REST path of the job resource. If this property is not specified when a job is created, the server generates a <code>job_id</code>.
.google.cloud.dataproc.v1.JobReference reference = 1;
getReference
in interface JobOrBuilder
public JobReferenceOrBuilder getReferenceOrBuilder()
Optional. The fully qualified reference to the job, which can be used to obtain the equivalent REST path of the job resource. If this property is not specified when a job is created, the server generates a <code>job_id</code>.
.google.cloud.dataproc.v1.JobReference reference = 1;
getReferenceOrBuilder
in interface JobOrBuilder
public boolean hasPlacement()
Required. Job information, including how, when, and where to run the job.
.google.cloud.dataproc.v1.JobPlacement placement = 2;
hasPlacement
in interface JobOrBuilder
public JobPlacement getPlacement()
Required. Job information, including how, when, and where to run the job.
.google.cloud.dataproc.v1.JobPlacement placement = 2;
getPlacement
in interface JobOrBuilder
public JobPlacementOrBuilder getPlacementOrBuilder()
Required. Job information, including how, when, and where to run the job.
.google.cloud.dataproc.v1.JobPlacement placement = 2;
getPlacementOrBuilder
in interface JobOrBuilder
public boolean hasHadoopJob()
Job is a Hadoop job.
.google.cloud.dataproc.v1.HadoopJob hadoop_job = 3;
hasHadoopJob
in interface JobOrBuilder
public HadoopJob getHadoopJob()
Job is a Hadoop job.
.google.cloud.dataproc.v1.HadoopJob hadoop_job = 3;
getHadoopJob
in interface JobOrBuilder
public HadoopJobOrBuilder getHadoopJobOrBuilder()
Job is a Hadoop job.
.google.cloud.dataproc.v1.HadoopJob hadoop_job = 3;
getHadoopJobOrBuilder
in interface JobOrBuilder
public boolean hasSparkJob()
Job is a Spark job.
.google.cloud.dataproc.v1.SparkJob spark_job = 4;
hasSparkJob
in interface JobOrBuilder
public SparkJob getSparkJob()
Job is a Spark job.
.google.cloud.dataproc.v1.SparkJob spark_job = 4;
getSparkJob
in interface JobOrBuilder
public SparkJobOrBuilder getSparkJobOrBuilder()
Job is a Spark job.
.google.cloud.dataproc.v1.SparkJob spark_job = 4;
getSparkJobOrBuilder
in interface JobOrBuilder
public boolean hasPysparkJob()
Job is a Pyspark job.
.google.cloud.dataproc.v1.PySparkJob pyspark_job = 5;
hasPysparkJob
in interface JobOrBuilder
public PySparkJob getPysparkJob()
Job is a Pyspark job.
.google.cloud.dataproc.v1.PySparkJob pyspark_job = 5;
getPysparkJob
in interface JobOrBuilder
public PySparkJobOrBuilder getPysparkJobOrBuilder()
Job is a Pyspark job.
.google.cloud.dataproc.v1.PySparkJob pyspark_job = 5;
getPysparkJobOrBuilder
in interface JobOrBuilder
public boolean hasHiveJob()
Job is a Hive job.
.google.cloud.dataproc.v1.HiveJob hive_job = 6;
hasHiveJob
in interface JobOrBuilder
public HiveJob getHiveJob()
Job is a Hive job.
.google.cloud.dataproc.v1.HiveJob hive_job = 6;
getHiveJob
in interface JobOrBuilder
public HiveJobOrBuilder getHiveJobOrBuilder()
Job is a Hive job.
.google.cloud.dataproc.v1.HiveJob hive_job = 6;
getHiveJobOrBuilder
in interface JobOrBuilder
public boolean hasPigJob()
Job is a Pig job.
.google.cloud.dataproc.v1.PigJob pig_job = 7;
hasPigJob
in interface JobOrBuilder
public PigJob getPigJob()
Job is a Pig job.
.google.cloud.dataproc.v1.PigJob pig_job = 7;
getPigJob
in interface JobOrBuilder
public PigJobOrBuilder getPigJobOrBuilder()
Job is a Pig job.
.google.cloud.dataproc.v1.PigJob pig_job = 7;
getPigJobOrBuilder
in interface JobOrBuilder
public boolean hasSparkSqlJob()
Job is a SparkSql job.
.google.cloud.dataproc.v1.SparkSqlJob spark_sql_job = 12;
hasSparkSqlJob
in interface JobOrBuilder
public SparkSqlJob getSparkSqlJob()
Job is a SparkSql job.
.google.cloud.dataproc.v1.SparkSqlJob spark_sql_job = 12;
getSparkSqlJob
in interface JobOrBuilder
public SparkSqlJobOrBuilder getSparkSqlJobOrBuilder()
Job is a SparkSql job.
.google.cloud.dataproc.v1.SparkSqlJob spark_sql_job = 12;
getSparkSqlJobOrBuilder
in interface JobOrBuilder
public boolean hasStatus()
Output-only. The job status. Additional application-specific status information may be contained in the <code>type_job</code> and <code>yarn_applications</code> fields.
.google.cloud.dataproc.v1.JobStatus status = 8;
hasStatus
in interface JobOrBuilder
public JobStatus getStatus()
Output-only. The job status. Additional application-specific status information may be contained in the <code>type_job</code> and <code>yarn_applications</code> fields.
.google.cloud.dataproc.v1.JobStatus status = 8;
getStatus
in interface JobOrBuilder
public JobStatusOrBuilder getStatusOrBuilder()
Output-only. The job status. Additional application-specific status information may be contained in the <code>type_job</code> and <code>yarn_applications</code> fields.
.google.cloud.dataproc.v1.JobStatus status = 8;
getStatusOrBuilder
in interface JobOrBuilder
public java.util.List<JobStatus> getStatusHistoryList()
Output-only. The previous job status.
repeated .google.cloud.dataproc.v1.JobStatus status_history = 13;
getStatusHistoryList
in interface JobOrBuilder
public java.util.List<? extends JobStatusOrBuilder> getStatusHistoryOrBuilderList()
Output-only. The previous job status.
repeated .google.cloud.dataproc.v1.JobStatus status_history = 13;
getStatusHistoryOrBuilderList
in interface JobOrBuilder
public int getStatusHistoryCount()
Output-only. The previous job status.
repeated .google.cloud.dataproc.v1.JobStatus status_history = 13;
getStatusHistoryCount
in interface JobOrBuilder
public JobStatus getStatusHistory(int index)
Output-only. The previous job status.
repeated .google.cloud.dataproc.v1.JobStatus status_history = 13;
getStatusHistory
in interface JobOrBuilder
public JobStatusOrBuilder getStatusHistoryOrBuilder(int index)
Output-only. The previous job status.
repeated .google.cloud.dataproc.v1.JobStatus status_history = 13;
getStatusHistoryOrBuilder
in interface JobOrBuilder
public java.util.List<YarnApplication> getYarnApplicationsList()
Output-only. The collection of YARN applications spun up by this job. **Beta** Feature: This report is available for testing purposes only. It may be changed before final release.
repeated .google.cloud.dataproc.v1.YarnApplication yarn_applications = 9;
getYarnApplicationsList
in interface JobOrBuilder
public java.util.List<? extends YarnApplicationOrBuilder> getYarnApplicationsOrBuilderList()
Output-only. The collection of YARN applications spun up by this job. **Beta** Feature: This report is available for testing purposes only. It may be changed before final release.
repeated .google.cloud.dataproc.v1.YarnApplication yarn_applications = 9;
getYarnApplicationsOrBuilderList
in interface JobOrBuilder
public int getYarnApplicationsCount()
Output-only. The collection of YARN applications spun up by this job. **Beta** Feature: This report is available for testing purposes only. It may be changed before final release.
repeated .google.cloud.dataproc.v1.YarnApplication yarn_applications = 9;
getYarnApplicationsCount
in interface JobOrBuilder
public YarnApplication getYarnApplications(int index)
Output-only. The collection of YARN applications spun up by this job. **Beta** Feature: This report is available for testing purposes only. It may be changed before final release.
repeated .google.cloud.dataproc.v1.YarnApplication yarn_applications = 9;
getYarnApplications
in interface JobOrBuilder
public YarnApplicationOrBuilder getYarnApplicationsOrBuilder(int index)
Output-only. The collection of YARN applications spun up by this job. **Beta** Feature: This report is available for testing purposes only. It may be changed before final release.
repeated .google.cloud.dataproc.v1.YarnApplication yarn_applications = 9;
getYarnApplicationsOrBuilder
in interface JobOrBuilder
public java.lang.String getDriverOutputResourceUri()
Output-only. A URI pointing to the location of the stdout of the job's driver program.
string driver_output_resource_uri = 17;
getDriverOutputResourceUri
in interface JobOrBuilder
public ByteString getDriverOutputResourceUriBytes()
Output-only. A URI pointing to the location of the stdout of the job's driver program.
string driver_output_resource_uri = 17;
getDriverOutputResourceUriBytes
in interface JobOrBuilder
public java.lang.String getDriverControlFilesUri()
Output-only. If present, the location of miscellaneous control files which may be used as part of job setup and handling. If not present, control files may be placed in the same location as `driver_output_uri`.
string driver_control_files_uri = 15;
getDriverControlFilesUri
in interface JobOrBuilder
public ByteString getDriverControlFilesUriBytes()
Output-only. If present, the location of miscellaneous control files which may be used as part of job setup and handling. If not present, control files may be placed in the same location as `driver_output_uri`.
string driver_control_files_uri = 15;
getDriverControlFilesUriBytes
in interface JobOrBuilder
public int getLabelsCount()
JobOrBuilder
Optional. The labels to associate with this job. Label **keys** must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). Label **values** may be empty, but, if present, must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be associated with a job.
map<string, string> labels = 18;
getLabelsCount
in interface JobOrBuilder
public boolean containsLabels(java.lang.String key)
Optional. The labels to associate with this job. Label **keys** must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). Label **values** may be empty, but, if present, must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be associated with a job.
map<string, string> labels = 18;
containsLabels
in interface JobOrBuilder
@Deprecated public java.util.Map<java.lang.String,java.lang.String> getLabels()
getLabelsMap()
instead.getLabels
in interface JobOrBuilder
public java.util.Map<java.lang.String,java.lang.String> getLabelsMap()
Optional. The labels to associate with this job. Label **keys** must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). Label **values** may be empty, but, if present, must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be associated with a job.
map<string, string> labels = 18;
getLabelsMap
in interface JobOrBuilder
public java.lang.String getLabelsOrDefault(java.lang.String key, java.lang.String defaultValue)
Optional. The labels to associate with this job. Label **keys** must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). Label **values** may be empty, but, if present, must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be associated with a job.
map<string, string> labels = 18;
getLabelsOrDefault
in interface JobOrBuilder
public java.lang.String getLabelsOrThrow(java.lang.String key)
Optional. The labels to associate with this job. Label **keys** must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). Label **values** may be empty, but, if present, must contain 1 to 63 characters, and must conform to [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be associated with a job.
map<string, string> labels = 18;
getLabelsOrThrow
in interface JobOrBuilder
public boolean hasScheduling()
Optional. Job scheduling configuration.
.google.cloud.dataproc.v1.JobScheduling scheduling = 20;
hasScheduling
in interface JobOrBuilder
public JobScheduling getScheduling()
Optional. Job scheduling configuration.
.google.cloud.dataproc.v1.JobScheduling scheduling = 20;
getScheduling
in interface JobOrBuilder
public JobSchedulingOrBuilder getSchedulingOrBuilder()
Optional. Job scheduling configuration.
.google.cloud.dataproc.v1.JobScheduling scheduling = 20;
getSchedulingOrBuilder
in interface JobOrBuilder
public final boolean isInitialized()
isInitialized
in interface MessageLiteOrBuilder
isInitialized
in class GeneratedMessageV3
public void writeTo(CodedOutputStream output) throws java.io.IOException
writeTo
in interface MessageLite
writeTo
in class GeneratedMessageV3
java.io.IOException
public int getSerializedSize()
getSerializedSize
in interface MessageLite
getSerializedSize
in class GeneratedMessageV3
public boolean equals(java.lang.Object obj)
equals
in interface Message
equals
in class AbstractMessage
public int hashCode()
hashCode
in interface Message
hashCode
in class AbstractMessage
public static Job parseFrom(java.nio.ByteBuffer data) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static Job parseFrom(java.nio.ByteBuffer data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static Job parseFrom(ByteString data) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static Job parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static Job parseFrom(byte[] data) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static Job parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferException
public static Job parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static Job parseFrom(java.io.InputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static Job parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static Job parseDelimitedFrom(java.io.InputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static Job parseFrom(CodedInputStream input) throws java.io.IOException
java.io.IOException
public static Job parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public Job.Builder newBuilderForType()
newBuilderForType
in interface Message
newBuilderForType
in interface MessageLite
public static Job.Builder newBuilder()
public static Job.Builder newBuilder(Job prototype)
public Job.Builder toBuilder()
toBuilder
in interface Message
toBuilder
in interface MessageLite
protected Job.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class GeneratedMessageV3
public static Job getDefaultInstance()
public Parser<Job> getParserForType()
getParserForType
in interface Message
getParserForType
in interface MessageLite
getParserForType
in class GeneratedMessageV3
public Job getDefaultInstanceForType()
getDefaultInstanceForType
in interface MessageLiteOrBuilder
getDefaultInstanceForType
in interface MessageOrBuilder