Struct google_api_proto::google::cloud::dataproc::v1::Job

pub struct Job {

    pub reference: Option<JobReference>,
    pub placement: Option<JobPlacement>,
    pub status: Option<JobStatus>,
    pub status_history: Vec<JobStatus>,
    pub yarn_applications: Vec<YarnApplication>,
    pub driver_output_resource_uri: String,
    pub driver_control_files_uri: String,
    pub labels: BTreeMap<String, String>,
    pub scheduling: Option<JobScheduling>,
    pub job_uuid: String,
    pub done: bool,
    pub driver_scheduling_config: Option<DriverSchedulingConfig>,
    pub type_job: Option<TypeJob>,
}

A Dataproc job resource.

Fields

reference: Option<JobReference>

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 job_id.

placement: Option<JobPlacement>

Required. Job information, including how, when, and where to run the job.

status: Option<JobStatus>

Output only. The job status. Additional application-specific status information may be contained in the type_job and yarn_applications fields.

status_history: Vec<JobStatus>

Output only. The previous job status.

yarn_applications: Vec<YarnApplication>

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.

driver_output_resource_uri: String

Output only. A URI pointing to the location of the stdout of the job’s driver program.

driver_control_files_uri: String

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.

labels: BTreeMap<String, String>

Optional. The labels to associate with this job. Label keys must contain 1 to 63 characters, and must conform to RFC 1035. Label values may be empty, but, if present, must contain 1 to 63 characters, and must conform to RFC 1035. No more than 32 labels can be associated with a job.

scheduling: Option<JobScheduling>

Optional. Job scheduling configuration.

job_uuid: String

Output only. A UUID that uniquely identifies a job within the project over time. This is in contrast to a user-settable reference.job_id that may be reused over time.

done: bool

Output only. Indicates whether the job is completed. If the value is false, the job is still in progress. If true, the job is completed, and status.state field will indicate if it was successful, failed, or cancelled.

driver_scheduling_config: Option<DriverSchedulingConfig>

Optional. Driver scheduling configuration.

type_job: Option<TypeJob>

Required. The application/framework-specific portion of the job.

Trait Implementations

impl Clone for Job

fn clone(&self) -> Job

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Job

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Job

fn default() -> Self

Returns the “default value” for a type.

impl Message for Job

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for Job

fn eq(&self, other: &Job) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Job