class_docstr: Submits a Spark SQL application to the underlying cluster; wraps the AnalyticDB Spark REST API.
  
  :param sql: The SQL query to execute.
  :param conf: Spark configuration properties.
  :param driver_resource_spec: The resource specifications of the Spark driver.
  :param executor_resource_spec: The resource specifications of each Spark executor.
  :param num_executors: number of executors to launch for this application.
  :param name: name of this application.
  :param cluster_id: The cluster ID of AnalyticDB MySQL 3.0 Data Lakehouse.
  :param rg_name: The name of resource group in AnalyticDB MySQL 3.0 Data Lakehouse cluster.
class_docstr_tok: ["Submits","a","Spark","SQL","application","to","the","underlying","cluster",";","wraps","the","AnalyticDB","Spark","REST","API",".",":","param","sql",":","The","SQL","query","to","execute",".",":","param","conf",":","Spark","configuration","properties",".",":","param","driver_resource_spec",":","The","resource","specifications","of","the","Spark","driver",".",":","param","executor_resource_spec",":","The","resource","specifications","of","each","Spark","executor",".",":","param","num_executors",":","number","of","executors","to","launch","for","this","application",".",":","param","name",":","name","of","this","application",".",":","param","cluster_id",":","The","cluster","ID","of","AnalyticDB","MySQL","3.0","Data","Lakehouse",".",":","param","rg_name",":","The","name","of","resource","group","in","AnalyticDB","MySQL","3.0","Data","Lakehouse","cluster","."]
code: def execute(self, context: Context) -> Any:
      submit_response = self.hook.submit_spark_sql(
          cluster_id=self._cluster_id,
          rg_name=self._rg_name,
          **self.spark_params,
      )
      self.app_id = submit_response.body.data.app_id
      self.monitor_application()
      return self.app_id
  
imports: from __future__ import annotations
  import time
  from functools import cached_property
  from typing import TYPE_CHECKING, Any, Sequence
  from deprecated.classic import deprecated
  from airflow.exceptions import AirflowException, AirflowProviderDeprecationWarning
  from airflow.models import BaseOperator
  from airflow.providers.alibaba.cloud.hooks.analyticdb_spark import AnalyticDBSparkHook, AppState
label_desc: Use image node_id 2 for calling the AnalyticDBSparkSQLOperator obj's underlying member method code with example usage: obj.execute(context) and returns: self