gravitino.api.job.job_template_change.SparkTemplateUpdate

class gravitino.api.job.job_template_change.SparkTemplateUpdate(new_executable: str | None = None, new_arguments: List[str] | None = None, new_environments: Dict[str, str] | None = None, new_custom_fields: Dict[str, str] | None = None, new_class_name: str | None = None, new_jars: List[str] | None = None, new_files: List[str] | None = None, new_archives: List[str] | None = None, new_configs: Dict[str, str] | None = None)

Bases: TemplateUpdate

A template update for spark job templates.

__init__(new_executable: str | None = None, new_arguments: List[str] | None = None, new_environments: Dict[str, str] | None = None, new_custom_fields: Dict[str, str] | None = None, new_class_name: str | None = None, new_jars: List[str] | None = None, new_files: List[str] | None = None, new_archives: List[str] | None = None, new_configs: Dict[str, str] | None = None)

Initialize a SparkTemplateUpdate.

Args:

new_executable: The new executable of the spark job template. new_arguments: The new arguments of the spark job template. new_environments: The new environments of the spark job template. new_custom_fields: The new custom fields of the spark job template. new_class_name: The new class name of the spark job template. new_jars: The new jars of the spark job template. new_files: The new files of the spark job template. new_archives: The new archives of the spark job template. new_configs: The new configs of the spark job template.

Methods

__init__([new_executable, new_arguments, ...])

Initialize a SparkTemplateUpdate.

get_new_archives()

Get the new archives of the spark job template.

get_new_arguments()

Get the new arguments of the job template.

get_new_class_name()

Get the new class name of the spark job template.

get_new_configs()

Get the new configs of the spark job template.

get_new_custom_fields()

Get the new custom fields of the job template.

get_new_environments()

Get the new environments of the job template.

get_new_executable()

Get the new executable of the job template.

get_new_files()

Get the new files of the spark job template.

get_new_jars()

Get the new jars of the spark job template.

get_new_archives() List[str] | None

Get the new archives of the spark job template.

Returns:

The new archives of the spark job template.

get_new_arguments() List[str] | None

Get the new arguments of the job template.

Returns:

The new arguments of the job template.

get_new_class_name() str | None

Get the new class name of the spark job template.

Returns:

The new class name of the spark job template.

get_new_configs() Dict[str, str] | None

Get the new configs of the spark job template.

Returns:

The new configs of the spark job template.

get_new_custom_fields() Dict[str, str] | None

Get the new custom fields of the job template.

Returns:

The new custom fields of the job template.

get_new_environments() Dict[str, str] | None

Get the new environments of the job template.

Returns:

The new environments of the job template.

get_new_executable() str | None

Get the new executable of the job template.

Returns:

The new executable of the job template.

get_new_files() List[str] | None

Get the new files of the spark job template.

Returns:

The new files of the spark job template.

get_new_jars() List[str] | None

Get the new jars of the spark job template.

Returns:

The new jars of the spark job template.