Cloud Dataproc V1beta2 API - Class Google::Cloud::Dataproc::V1beta2::OrderedJob (v0.6.3)

Reference documentation and code samples for the Cloud Dataproc V1beta2 API class Google::Cloud::Dataproc::V1beta2::OrderedJob.

A job executed by the workflow.

Inherits

• Object

Extended By

• Google::Protobuf::MessageExts::ClassMethods

Includes

• Google::Protobuf::MessageExts

Methods

#hadoop_job

def hadoop_job() -> ::Google::Cloud::Dataproc::V1beta2::HadoopJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::HadoopJob) — Optional. Job is a Hadoop job.

#hadoop_job=

def hadoop_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::HadoopJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::HadoopJob) — Optional. Job is a Hadoop job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::HadoopJob) — Optional. Job is a Hadoop job.

#hive_job

def hive_job() -> ::Google::Cloud::Dataproc::V1beta2::HiveJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::HiveJob) — Optional. Job is a Hive job.

#hive_job=

def hive_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::HiveJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::HiveJob) — Optional. Job is a Hive job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::HiveJob) — Optional. Job is a Hive job.

#labels

def labels() -> ::Google::Protobuf::Map{::String => ::String}

Returns

• (::Google::Protobuf::Map{::String => ::String}) — Optional. The labels to associate with this job.

  Label keys must be between 1 and 63 characters long, and must conform to the following regular expression: [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62}

  Label values must be between 1 and 63 characters long, and must conform to the following regular expression: [\p{Ll}\p{Lo}\p{N}_-]{0,63}

  No more than 32 labels can be associated with a given job.

#labels=

def labels=(value) -> ::Google::Protobuf::Map{::String => ::String}

Parameter

• value (::Google::Protobuf::Map{::String => ::String}) — Optional. The labels to associate with this job.

  Label keys must be between 1 and 63 characters long, and must conform to the following regular expression: [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62}

  Label values must be between 1 and 63 characters long, and must conform to the following regular expression: [\p{Ll}\p{Lo}\p{N}_-]{0,63}

  No more than 32 labels can be associated with a given job.

Returns

• (::Google::Protobuf::Map{::String => ::String}) — Optional. The labels to associate with this job.

  Label keys must be between 1 and 63 characters long, and must conform to the following regular expression: [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62}

  Label values must be between 1 and 63 characters long, and must conform to the following regular expression: [\p{Ll}\p{Lo}\p{N}_-]{0,63}

  No more than 32 labels can be associated with a given job.

#pig_job

def pig_job() -> ::Google::Cloud::Dataproc::V1beta2::PigJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::PigJob) — Optional. Job is a Pig job.

#pig_job=

def pig_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::PigJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::PigJob) — Optional. Job is a Pig job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::PigJob) — Optional. Job is a Pig job.

#prerequisite_step_ids

def prerequisite_step_ids() -> ::Array<::String>

Returns

• (::Array<::String>) — Optional. The optional list of prerequisite job step_ids. If not specified, the job will start at the beginning of workflow.

#prerequisite_step_ids=

def prerequisite_step_ids=(value) -> ::Array<::String>

Parameter

• value (::Array<::String>) — Optional. The optional list of prerequisite job step_ids. If not specified, the job will start at the beginning of workflow.

Returns

• (::Array<::String>) — Optional. The optional list of prerequisite job step_ids. If not specified, the job will start at the beginning of workflow.

#presto_job

def presto_job() -> ::Google::Cloud::Dataproc::V1beta2::PrestoJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::PrestoJob) — Optional. Job is a Presto job.

#presto_job=

def presto_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::PrestoJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::PrestoJob) — Optional. Job is a Presto job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::PrestoJob) — Optional. Job is a Presto job.

#pyspark_job

def pyspark_job() -> ::Google::Cloud::Dataproc::V1beta2::PySparkJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::PySparkJob) — Optional. Job is a PySpark job.

#pyspark_job=

def pyspark_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::PySparkJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::PySparkJob) — Optional. Job is a PySpark job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::PySparkJob) — Optional. Job is a PySpark job.

#scheduling

def scheduling() -> ::Google::Cloud::Dataproc::V1beta2::JobScheduling

Returns

• (::Google::Cloud::Dataproc::V1beta2::JobScheduling) — Optional. Job scheduling configuration.

#scheduling=

def scheduling=(value) -> ::Google::Cloud::Dataproc::V1beta2::JobScheduling

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::JobScheduling) — Optional. Job scheduling configuration.

Returns

• (::Google::Cloud::Dataproc::V1beta2::JobScheduling) — Optional. Job scheduling configuration.

#spark_job

def spark_job() -> ::Google::Cloud::Dataproc::V1beta2::SparkJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::SparkJob) — Optional. Job is a Spark job.

#spark_job=

def spark_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::SparkJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::SparkJob) — Optional. Job is a Spark job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::SparkJob) — Optional. Job is a Spark job.

#spark_r_job

def spark_r_job() -> ::Google::Cloud::Dataproc::V1beta2::SparkRJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::SparkRJob) — Optional. Job is a SparkR job.

#spark_r_job=

def spark_r_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::SparkRJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::SparkRJob) — Optional. Job is a SparkR job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::SparkRJob) — Optional. Job is a SparkR job.

#spark_sql_job

def spark_sql_job() -> ::Google::Cloud::Dataproc::V1beta2::SparkSqlJob

Returns

• (::Google::Cloud::Dataproc::V1beta2::SparkSqlJob) — Optional. Job is a SparkSql job.

#spark_sql_job=

def spark_sql_job=(value) -> ::Google::Cloud::Dataproc::V1beta2::SparkSqlJob

Parameter

• value (::Google::Cloud::Dataproc::V1beta2::SparkSqlJob) — Optional. Job is a SparkSql job.

Returns

• (::Google::Cloud::Dataproc::V1beta2::SparkSqlJob) — Optional. Job is a SparkSql job.

#step_id

def step_id() -> ::String

Returns

• (::String) — Required. The step id. The id must be unique among all jobs within the template.

  The step id is used as prefix for job id, as job goog-dataproc-workflow-step-id label, and in prerequisiteStepIds field from other steps.

  The id must contain only letters (a-z, A-Z), numbers (0-9), underscores (_), and hyphens (-). Cannot begin or end with underscore or hyphen. Must consist of between 3 and 50 characters.

#step_id=

def step_id=(value) -> ::String

Parameter

• value (::String) — Required. The step id. The id must be unique among all jobs within the template.

  The step id is used as prefix for job id, as job goog-dataproc-workflow-step-id label, and in prerequisiteStepIds field from other steps.

  The id must contain only letters (a-z, A-Z), numbers (0-9), underscores (_), and hyphens (-). Cannot begin or end with underscore or hyphen. Must consist of between 3 and 50 characters.

Returns

• (::String) — Required. The step id. The id must be unique among all jobs within the template.

  The step id is used as prefix for job id, as job goog-dataproc-workflow-step-id label, and in prerequisiteStepIds field from other steps.

  The id must contain only letters (a-z, A-Z), numbers (0-9), underscores (_), and hyphens (-). Cannot begin or end with underscore or hyphen. Must consist of between 3 and 50 characters.