def execute(self, context):
self.hook = SqoopHook(<EOL>conn_id=self.conn_id,<EOL>verbose=self.verbose,<EOL>num_mappers=self.num_mappers,<EOL>hcatalog_database=self.hcatalog_database,<EOL>hcatalog_table=self.hcatalog_table,<EOL>properties=self.properties<EOL>)<EOL>if self.cmd_type == '<STR_LIT>':<EOL><INDENT>self.hook.export_table(<EOL>table=self.table,<EOL>export_dir=self.export_dir,<EOL>input_null_string=self.input_null_string,<EOL>input_null_non_string=self.input_null_non_string,<EOL>staging_table=self.staging_table,<EOL>clear_staging_table=self.clear_staging_table,<EOL>enclosed_by=self.enclosed_by,<EOL>escaped_by=self.escaped_by,<EOL>input_fields_terminated_by=self.input_fields_terminated_by,<EOL>input_lines_terminated_by=self.input_lines_terminated_by,<EOL>input_optionally_enclosed_by=self.input_optionally_enclosed_by,<EOL>batch=self.batch,<EOL>relaxed_isolation=self.relaxed_isolation,<EOL>extra_export_options=self.extra_export_options)<EOL><DEDENT>elif self.cmd_type == '<STR_LIT>':<EOL><INDENT>if self.create_hcatalog_table:<EOL><INDENT>self.extra_import_options['<STR_LIT>'] = '<STR_LIT>'<EOL><DEDENT>if self.table and self.query:<EOL><INDENT>raise AirflowException(<EOL>'<STR_LIT>'<EOL>)<EOL><DEDENT>if self.table:<EOL><INDENT>self.hook.import_table(<EOL>table=self.table,<EOL>target_dir=self.target_dir,<EOL>append=self.append,<EOL>file_type=self.file_type,<EOL>columns=self.columns,<EOL>split_by=self.split_by,<EOL>where=self.where,<EOL>direct=self.direct,<EOL>driver=self.driver,<EOL>extra_import_options=self.extra_import_options)<EOL><DEDENT>elif self.query:<EOL><INDENT>self.hook.import_query(<EOL>query=self.query,<EOL>target_dir=self.target_dir,<EOL>append=self.append,<EOL>file_type=self.file_type,<EOL>split_by=self.split_by,<EOL>direct=self.direct,<EOL>driver=self.driver,<EOL>extra_import_options=self.extra_import_options)<EOL><DEDENT>else:<EOL><INDENT>raise AirflowException(<EOL>"<STR_LIT>"<EOL>)<EOL><DEDENT><DEDENT>else:<EOL><INDENT>raise AirflowException("<STR_LIT>")<EOL><DEDENT>
Execute sqoop job