Struct gapi_grpc::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: HashMap<String, String>,
    pub scheduling: Option<JobScheduling>,
    pub job_uuid: String,
    pub done: bool,
    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: HashMap<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.

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.

pub 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() -> Job

Returns the “default value” for a type.

impl Message for Job

fn encode_raw<B>(&self, buf: &mut B) where
    B: BufMut, 

fn merge_field<B>(
    &mut self,
    tag: u32,
    wire_type: WireType,
    buf: &mut B,
    ctx: DecodeContext
) -> Result<(), DecodeError> where
    B: Buf, 

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.

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

Encodes the message to a buffer.

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

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

pub fn decode<B>(buf: B) -> Result<Self, DecodeError> where
    Self: Default,
    B: Buf, 

Decodes an instance of the message from a buffer.

pub fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
    Self: Default,
    B: Buf, 

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

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

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

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

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

impl PartialEq<Job> 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: &Job) -> bool

This method tests for !=.

impl StructuralPartialEq for Job