Class: Google::Apis::DataprocV1beta2::PigJob
- Inherits:
-
Object
- Object
- Google::Apis::DataprocV1beta2::PigJob
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataproc_v1beta2/classes.rb,
generated/google/apis/dataproc_v1beta2/representations.rb,
generated/google/apis/dataproc_v1beta2/representations.rb
Overview
A Cloud Dataproc job for running Apache Pig (https://pig.apache.org/) queries on YARN.
Instance Attribute Summary collapse
-
#continue_on_failure ⇒ Boolean
(also: #continue_on_failure?)
Optional.
-
#jar_file_uris ⇒ Array<String>
Optional.
-
#logging_config ⇒ Google::Apis::DataprocV1beta2::LoggingConfig
The runtime logging config of the job.
-
#properties ⇒ Hash<String,String>
Optional.
-
#query_file_uri ⇒ String
The HCFS URI of the script that contains the Pig queries.
-
#query_list ⇒ Google::Apis::DataprocV1beta2::QueryList
A list of queries to run on a cluster.
-
#script_variables ⇒ Hash<String,String>
Optional.
Instance Method Summary collapse
-
#initialize(**args) ⇒ PigJob
constructor
A new instance of PigJob.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ PigJob
Returns a new instance of PigJob
2199 2200 2201 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2199 def initialize(**args) update!(**args) end |
Instance Attribute Details
#continue_on_failure ⇒ Boolean Also known as: continue_on_failure?
Optional. Whether to continue executing queries if a query fails. The default
value is false. Setting to true can be useful when executing independent
parallel queries.
Corresponds to the JSON property continueOnFailure
2161 2162 2163 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2161 def continue_on_failure @continue_on_failure end |
#jar_file_uris ⇒ Array<String>
Optional. HCFS URIs of jar files to add to the CLASSPATH of the Pig Client and
Hadoop MapReduce (MR) tasks. Can contain Pig UDFs.
Corresponds to the JSON property jarFileUris
2168 2169 2170 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2168 def jar_file_uris @jar_file_uris end |
#logging_config ⇒ Google::Apis::DataprocV1beta2::LoggingConfig
The runtime logging config of the job.
Corresponds to the JSON property loggingConfig
2173 2174 2175 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2173 def logging_config @logging_config end |
#properties ⇒ Hash<String,String>
Optional. A mapping of property names to values, used to configure Pig.
Properties that conflict with values set by the Cloud Dataproc API may be
overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml, /etc/
pig/conf/pig.properties, and classes in user code.
Corresponds to the JSON property properties
2181 2182 2183 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2181 def properties @properties end |
#query_file_uri ⇒ String
The HCFS URI of the script that contains the Pig queries.
Corresponds to the JSON property queryFileUri
2186 2187 2188 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2186 def query_file_uri @query_file_uri end |
#query_list ⇒ Google::Apis::DataprocV1beta2::QueryList
A list of queries to run on a cluster.
Corresponds to the JSON property queryList
2191 2192 2193 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2191 def query_list @query_list end |
#script_variables ⇒ Hash<String,String>
Optional. Mapping of query variable names to values (equivalent to the Pig
command: name=[value]).
Corresponds to the JSON property scriptVariables
2197 2198 2199 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2197 def script_variables @script_variables end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
2204 2205 2206 2207 2208 2209 2210 2211 2212 |
# File 'generated/google/apis/dataproc_v1beta2/classes.rb', line 2204 def update!(**args) @continue_on_failure = args[:continue_on_failure] if args.key?(:continue_on_failure) @jar_file_uris = args[:jar_file_uris] if args.key?(:jar_file_uris) @logging_config = args[:logging_config] if args.key?(:logging_config) @properties = args[:properties] if args.key?(:properties) @query_file_uri = args[:query_file_uri] if args.key?(:query_file_uri) @query_list = args[:query_list] if args.key?(:query_list) @script_variables = args[:script_variables] if args.key?(:script_variables) end |