class_docstr: Moves data from Hive to MySQL.
  
  Note that for now the data is loaded into memory before being pushed
  to MySQL, so this operator should be used for smallish amount of data.
  
  :param sql: SQL query to execute against Hive server. (templated)
  :param mysql_table: target MySQL table, use dot notation to target a
      specific database. (templated)
  :param mysql_conn_id: source mysql connection
  :param hiveserver2_conn_id: Reference to the
      :ref:`Hive Server2 thrift service connection id <howto/connection:hiveserver2>`.
  :param mysql_preoperator: sql statement to run against mysql prior to
      import, typically use to truncate of delete in place
      of the data coming in, allowing the task to be idempotent (running
      the task twice won't double load data). (templated)
  :param mysql_postoperator: sql statement to run against mysql after the
      import, typically used to move data from staging to
      production and issue cleanup commands. (templated)
  :param bulk_load: flag to use bulk_load option.  This loads mysql directly
      from a tab-delimited text file using the LOAD DATA LOCAL INFILE command. The MySQL
      server must support loading local files via this command (it is disabled by default).
  
  :param hive_conf:
class_docstr_tok: ["Moves","data","from","Hive","to","MySQL",".","Note","that","for","now","the","data","is","loaded","into","memory","before","being","pushed","to","MySQL",",","so","this","operator","should","be","used","for","smallish","amount","of","data",".",":","param","sql",":","SQL","query","to","execute","against","Hive","server",".","(","templated",")",":","param","mysql_table",":","target","MySQL","table",",","use","dot","notation","to","target","a","specific","database",".","(","templated",")",":","param","mysql_conn_id",":","source","mysql","connection",":","param","hiveserver2_conn_id",":","Reference","to","the",":","ref",":","`","Hive","Server2","thrift","service","connection","id","<","howto\/connection",":","hiveserver2",">","`",".",":","param","mysql_preoperator",":","sql","statement","to","run","against","mysql","prior","to","import",",","typically","use","to","truncate","of","delete","in","place","of","the","data","coming","in",",","allowing","the","task","to","be","idempotent","(","running","the","task","twice","wo","n't","double","load","data",")",".","(","templated",")",":","param","mysql_postoperator",":","sql","statement","to","run","against","mysql","after","the","import",",","typically","used","to","move","data","from","staging","to","production","and","issue","cleanup","commands",".","(","templated",")",":","param","bulk_load",":","flag","to","use","bulk_load","option",".","This","loads","mysql","directly","from","a","tab-delimited","text","file","using","the","LOAD","DATA","LOCAL","INFILE","command",".","The","MySQL","server","must","support","loading","local","files","via","this","command","(","it","is","disabled","by","default",")",".",":","param","hive_conf",":"]
code: def __init__(
      self,
      *,
      sql: str,
      mysql_table: str,
      hiveserver2_conn_id: str = "hiveserver2_default",
      mysql_conn_id: str = "mysql_default",
      mysql_preoperator: str | None = None,
      mysql_postoperator: str | None = None,
      bulk_load: bool = False,
      hive_conf: dict | None = None,
      **kwargs,
  ) -> None:
      super().__init__(**kwargs)
      self.sql = sql
      self.mysql_table = mysql_table
      self.mysql_conn_id = mysql_conn_id
      self.mysql_preoperator = mysql_preoperator
      self.mysql_postoperator = mysql_postoperator
      self.hiveserver2_conn_id = hiveserver2_conn_id
      self.bulk_load = bulk_load
      self.hive_conf = hive_conf
  
file_path: airflow/airflow/providers/apache/hive/transfers/hive_to_mysql.py
imports: from __future__ import annotations
  from tempfile import NamedTemporaryFile
  from typing import TYPE_CHECKING, Sequence
  from airflow.models import BaseOperator
  from airflow.providers.apache.hive.hooks.hive import HiveServer2Hook
  from airflow.providers.mysql.hooks.mysql import MySqlHook
  from airflow.utils.operator_helpers import context_to_airflow_vars
label_desc: Use image node_id 1 to create a new HiveToMySqlOperator object from inherited base classes: BaseOperator with example: obj = HiveToMySqlOperator()