def execute(self, context):
self._hook = SparkSubmitHook(<EOL>conf=self._conf,<EOL>conn_id=self._conn_id,<EOL>files=self._files,<EOL>py_files=self._py_files,<EOL>archives=self._archives,<EOL>driver_class_path=self._driver_class_path,<EOL>jars=self._jars,<EOL>java_class=self._java_class,<EOL>packages=self._packages,<EOL>exclude_packages=self._exclude_packages,<EOL>repositories=self._repositories,<EOL>total_executor_cores=self._total_executor_cores,<EOL>executor_cores=self._executor_cores,<EOL>executor_memory=self._executor_memory,<EOL>driver_memory=self._driver_memory,<EOL>keytab=self._keytab,<EOL>principal=self._principal,<EOL>name=self._name,<EOL>num_executors=self._num_executors,<EOL>application_args=self._application_args,<EOL>env_vars=self._env_vars,<EOL>verbose=self._verbose,<EOL>spark_binary=self._spark_binary<EOL>)<EOL>self._hook.submit(self._application)<EOL>
Call the SparkSubmitHook to run the provided spark job