User-specified config for running a Spark task.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#archive_uris
def archive_uris() -> ::Array<::String>
Returns
- (::Array<::String>) — Optional. Cloud Storage URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
#archive_uris=
def archive_uris=(value) -> ::Array<::String>
Parameter
- value (::Array<::String>) — Optional. Cloud Storage URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
Returns
- (::Array<::String>) — Optional. Cloud Storage URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.
#file_uris
def file_uris() -> ::Array<::String>
Returns
- (::Array<::String>) — Optional. Cloud Storage URIs of files to be placed in the working directory of each executor.
#file_uris=
def file_uris=(value) -> ::Array<::String>
Parameter
- value (::Array<::String>) — Optional. Cloud Storage URIs of files to be placed in the working directory of each executor.
Returns
- (::Array<::String>) — Optional. Cloud Storage URIs of files to be placed in the working directory of each executor.
#infrastructure_spec
def infrastructure_spec() -> ::Google::Cloud::Dataplex::V1::Task::InfrastructureSpec
Returns
- (::Google::Cloud::Dataplex::V1::Task::InfrastructureSpec) — Optional. Infrastructure specification for the execution.
#infrastructure_spec=
def infrastructure_spec=(value) -> ::Google::Cloud::Dataplex::V1::Task::InfrastructureSpec
Parameter
- value (::Google::Cloud::Dataplex::V1::Task::InfrastructureSpec) — Optional. Infrastructure specification for the execution.
Returns
- (::Google::Cloud::Dataplex::V1::Task::InfrastructureSpec) — Optional. Infrastructure specification for the execution.
#main_class
def main_class() -> ::String
Returns
-
(::String) — The name of the driver's main class. The jar file that contains the
class must be in the default CLASSPATH or specified in
jar_file_uris
. The execution args are passed in as a sequence of named process arguments (--key=value
).
#main_class=
def main_class=(value) -> ::String
Parameter
-
value (::String) — The name of the driver's main class. The jar file that contains the
class must be in the default CLASSPATH or specified in
jar_file_uris
. The execution args are passed in as a sequence of named process arguments (--key=value
).
Returns
-
(::String) — The name of the driver's main class. The jar file that contains the
class must be in the default CLASSPATH or specified in
jar_file_uris
. The execution args are passed in as a sequence of named process arguments (--key=value
).
#main_jar_file_uri
def main_jar_file_uri() -> ::String
Returns
-
(::String) — The Cloud Storage URI of the jar file that contains the main class.
The execution args are passed in as a sequence of named process
arguments (
--key=value
).
#main_jar_file_uri=
def main_jar_file_uri=(value) -> ::String
Parameter
-
value (::String) — The Cloud Storage URI of the jar file that contains the main class.
The execution args are passed in as a sequence of named process
arguments (
--key=value
).
Returns
-
(::String) — The Cloud Storage URI of the jar file that contains the main class.
The execution args are passed in as a sequence of named process
arguments (
--key=value
).
#python_script_file
def python_script_file() -> ::String
Returns
-
(::String) — The Gcloud Storage URI of the main Python file to use as the driver.
Must be a .py file. The execution args are passed in as a sequence of
named process arguments (
--key=value
).
#python_script_file=
def python_script_file=(value) -> ::String
Parameter
-
value (::String) — The Gcloud Storage URI of the main Python file to use as the driver.
Must be a .py file. The execution args are passed in as a sequence of
named process arguments (
--key=value
).
Returns
-
(::String) — The Gcloud Storage URI of the main Python file to use as the driver.
Must be a .py file. The execution args are passed in as a sequence of
named process arguments (
--key=value
).
#sql_script
def sql_script() -> ::String
Returns
-
(::String) — The query text.
The execution args are used to declare a set of script variables
(
set key="value";
).
#sql_script=
def sql_script=(value) -> ::String
Parameter
-
value (::String) — The query text.
The execution args are used to declare a set of script variables
(
set key="value";
).
Returns
-
(::String) — The query text.
The execution args are used to declare a set of script variables
(
set key="value";
).
#sql_script_file
def sql_script_file() -> ::String
Returns
-
(::String) — A reference to a query file. This can be the Cloud Storage URI of the
query file or it can the path to a SqlScript Content. The execution
args are used to declare a set of script variables
(
set key="value";
).
#sql_script_file=
def sql_script_file=(value) -> ::String
Parameter
-
value (::String) — A reference to a query file. This can be the Cloud Storage URI of the
query file or it can the path to a SqlScript Content. The execution
args are used to declare a set of script variables
(
set key="value";
).
Returns
-
(::String) — A reference to a query file. This can be the Cloud Storage URI of the
query file or it can the path to a SqlScript Content. The execution
args are used to declare a set of script variables
(
set key="value";
).