HiveServer2Hook

Apache Hive

Wrapper around the pyhive library

View on GitHub

Last Updated: Mar. 21, 2023

Access Instructions

Install the Apache Hive provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

hiveserver2_conn_idReference to the :ref: Hive Server2 thrift service connection id .
schemaHive database name.

Documentation

Wrapper around the pyhive library

Notes: * the default auth_mechanism is PLAIN, to override it you can specify it in the extra of your connection in the UI * the default for run_set_variable_statements is true, if you are using impala you may need to set it to false in the extra of your connection in the UI

Was this page helpful?