Snowflake Hive Metastore Connector

The Snowflake Hive metastore connector provides an easy way to query Hive-managed data via Snowflake. Once installed, the connector listens to Hive metastore events and creates the equivalent Snowflake objects. See also: https://docs.snowflake.net/manuals/user-guide/tables-external-hive.html

Installation:

1. Create a new file named 'snowflake-config.xml' to the same directory that contains hive-site.xml. This will be the configuration file for the connector. This configuration file should look like:

   <configuration>
     <property>
       <name>snowflake.jdbc.username</name>
       <value>...</value>
     </property>
     <property>
       <name>snowflake.jdbc.password</name>
       <value>...</value>
     </property>
     <property>
       <name>snowflake.jdbc.role</name>
       <value>...</value>
     </property>
     <property>
       <name>snowflake.jdbc.account</name>
       <value>...</value>
     </property>
     <property>
       <name>snowflake.jdbc.db</name>
       <value>...</value>
     </property>
     <property>
       <name>snowflake.jdbc.schema</name>
       <value>...</value>
     </property>
     <property>
       <name>snowflake.jdbc.connection</name>
       <value>jdbc:snowflake://account.snowflakecomputing.com</value>
     </property>
     <property>
       <name>snowflake.hive-metastore-listener.integration</name>
       <value>...</value>
     </property>
   </configuration>

2. Package the jar by running:

   mvn package

   Or download the jar from Maven: https://repo1.maven.org/maven2/net/snowflake/

3. Copy the jar into the Hive classpath

4. Update the Hive metastore configuration to point to the listener. To do this, simply add the following section to hive-site.xml:

   <configuration>
     ...
     <property>
       <name>hive.metastore.event.listeners</name>
       <value>net.snowflake.hivemetastoreconnector.SnowflakeHiveListener</value>
     </property>
   </configuration>

5. Restart the Hive metastore.

Usage:

1. In Hive, touch partitions to be used in Snowflake:

   alter table <table_name> touch partition <partition_spec>;
   

   Or for non-partitioned Hive tables:

   alter table <table_name> touch;
   

2. Query the table in Snowflake:

   select * from <table_name>;