Managed Spark API, gRPC: JobService.Create
Creates a job for Spark cluster.
gRPC request
rpc Create (CreateJobRequest) returns (operation.Operation)
CreateJobRequest
{
"cluster_id": "string",
"name": "string",
// Includes only one of the fields `spark_job`, `pyspark_job`, `spark_connect_job`
"spark_job": {
"args": [
"string"
],
"jar_file_uris": [
"string"
],
"file_uris": [
"string"
],
"archive_uris": [
"string"
],
"properties": "map<string, string>",
"main_jar_file_uri": "string",
"main_class": "string",
"packages": [
"string"
],
"repositories": [
"string"
],
"exclude_packages": [
"string"
]
},
"pyspark_job": {
"args": [
"string"
],
"jar_file_uris": [
"string"
],
"file_uris": [
"string"
],
"archive_uris": [
"string"
],
"properties": "map<string, string>",
"main_python_file_uri": "string",
"python_file_uris": [
"string"
],
"packages": [
"string"
],
"repositories": [
"string"
],
"exclude_packages": [
"string"
]
},
"spark_connect_job": {
"jar_file_uris": [
"string"
],
"file_uris": [
"string"
],
"archive_uris": [
"string"
],
"properties": "map<string, string>",
"packages": [
"string"
],
"repositories": [
"string"
],
"exclude_packages": [
"string"
]
},
// end of the list of possible fields
"service_account_id": "string"
}
|
Field |
Description |
|
cluster_id |
string Required field. ID of the cluster to create Spark job in. The maximum string length in characters is 50. |
|
name |
string Optional. Name of the job. The string length in characters must be less than 256. Value must match the regular expression |
|
spark_job |
Includes only one of the fields |
|
pyspark_job |
Includes only one of the fields |
|
spark_connect_job |
Includes only one of the fields |
|
service_account_id |
string Service account used to access Cloud resources. The maximum string length in characters is 50. |
SparkJob
Spark Job.
|
Field |
Description |
|
args[] |
string Optional arguments to pass to the driver. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
jar_file_uris[] |
string Jar file URIs to add to the CLASSPATHs of the Spark driver and tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
file_uris[] |
string URIs of files to be copied to the working directory of Spark drivers and distributed tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
archive_uris[] |
string URIs of archives to be extracted in the working directory of Spark drivers and tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
properties |
object (map<string, string>) A mapping of property names to values, used to configure Spark. The maximum string length in characters for each value is 256. The string length in characters for each key must be 1-128. Each key must match the regular expression |
|
main_jar_file_uri |
string Required field. The HCFS URI of the jar file containing the main class. The string length in characters must be less than 2048. |
|
main_class |
string The name of the driver's main class. The string length in characters must be less than 256. |
|
packages[] |
string List of maven coordinates of jars to include on the driver and executor classpaths. The string length in characters for each value must be less than 256. The maximum number of elements is 100. |
|
repositories[] |
string List of additional remote repositories to search for the maven coordinates given with --packages. The string length in characters for each value must be less than 2048. The maximum number of elements is 10. |
|
exclude_packages[] |
string List of groupId:artifactId, to exclude while resolving the dependencies provided in --packages to avoid dependency conflicts. The string length in characters for each value must be less than 256. The maximum number of elements is 100. |
PysparkJob
Pyspark Job.
|
Field |
Description |
|
args[] |
string Optional arguments to pass to the driver. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
jar_file_uris[] |
string Jar file URIs to add to the CLASSPATHs of the Spark driver and tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
file_uris[] |
string URIs of files to be copied to the working directory of Spark drivers and distributed tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
archive_uris[] |
string URIs of archives to be extracted in the working directory of Spark drivers and tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
properties |
object (map<string, string>) A mapping of property names to values, used to configure Spark. The maximum string length in characters for each value is 256. The string length in characters for each key must be 1-128. Each key must match the regular expression |
|
main_python_file_uri |
string Required field. URI of the main Python file to use as the driver. Must be a .py file. The string length in characters must be less than 2048. |
|
python_file_uris[] |
string URIs of Python files to pass to the PySpark framework. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
packages[] |
string List of maven coordinates of jars (groupId:artifactId:version) to include on the driver and executor classpaths. The string length in characters for each value must be less than 256. The maximum number of elements is 100. |
|
repositories[] |
string List of additional remote repositories to search for the maven coordinates given with --packages. The string length in characters for each value must be less than 2048. The maximum number of elements is 10. |
|
exclude_packages[] |
string List of groupId:artifactId, to exclude while resolving the dependencies provided in --packages to avoid dependency conflicts. The string length in characters for each value must be less than 256. The maximum number of elements is 100. |
SparkConnectJob
Spark-connect Job.
|
Field |
Description |
|
jar_file_uris[] |
string Jar file URIs to add to the CLASSPATHs of the Spark driver and tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
file_uris[] |
string URIs of files to be copied to the working directory of Spark drivers and distributed tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
archive_uris[] |
string URIs of archives to be extracted in the working directory of Spark drivers and tasks. The string length in characters for each value must be less than 2048. The maximum number of elements is 100. |
|
properties |
object (map<string, string>) A mapping of property names to values, used to configure Spark. The maximum string length in characters for each value is 256. The string length in characters for each key must be 1-128. Each key must match the regular expression |
|
packages[] |
string List of maven coordinates of jars to include on the driver and executor classpaths. The string length in characters for each value must be less than 256. The maximum number of elements is 100. |
|
repositories[] |
string List of additional remote repositories to search for the maven coordinates given with --packages. The string length in characters for each value must be less than 2048. The maximum number of elements is 10. |
|
exclude_packages[] |
string List of groupId:artifactId, to exclude while resolving the dependencies provided in --packages to avoid dependency conflicts. The string length in characters for each value must be less than 256. The maximum number of elements is 100. |
operation.Operation
{
"id": "string",
"description": "string",
"created_at": "google.protobuf.Timestamp",
"created_by": "string",
"modified_at": "google.protobuf.Timestamp",
"done": "bool",
"metadata": "google.protobuf.Any",
// Includes only one of the fields `error`, `response`
"error": "google.rpc.Status",
"response": "google.protobuf.Any"
// end of the list of possible fields
}
An Operation resource. For more information, see Operation.
|
Field |
Description |
|
id |
string ID of the operation. |
|
description |
string Description of the operation. 0-256 characters long. |
|
created_at |
Creation timestamp. |
|
created_by |
string ID of the user or service account who initiated the operation. |
|
modified_at |
The time when the Operation resource was last modified. |
|
done |
bool If the value is |
|
metadata |
Service-specific metadata associated with the operation. |
|
error |
The error result of the operation in case of failure or cancellation. Includes only one of the fields The operation result. |
|
response |
The normal response of the operation in case of success. Includes only one of the fields The operation result. |