Apache Hive

This documentation describes the integration of MindsDB with Apache Hive, a data warehouse software project built on top of Apache Hadoop for providing data query and analysis. Hive gives an SQL-like interface to query data stored in various databases and file systems that integrate with Hadoop. The integration allows MindsDB to access data from Apache Hive and enhance Apache Hive with AI capabilities.

​

Prerequisites

Before proceeding, ensure the following prerequisites are met:

1. Install MindsDB locally via Docker or Docker Desktop.
2. To connect Apache Hive to MindsDB, install the required dependencies following this instruction.

​

Connection

Establish a connection to Apache Hive from MindsDB by executing the following SQL command and providing its handler name as an engine.

CREATE DATABASE hive_datasource
WITH
  engine = 'hive',
  parameters = {
    "username": "demo_user",
    "password": "demo_password",
    "host": "127.0.0.1",
    "database": "default"
  };

Required connection parameters include the following:

• host: The hostname, IP address, or URL of the Apache Hive server.
• database: The name of the Apache Hive database to connect to.

Optional connection parameters include the following:

• username: The username for the Apache Hive database.
• password: The password for the Apache Hive database.
• port: The port number for connecting to the Apache Hive server. Default is 10000.
• auth: The authentication mechanism to use. Default is CUSTOM. Other options are NONE, NOSASL, KERBEROS and LDAP.

​

Usage

Retrieve data from a specified table by providing the integration and table names:

SELECT *
FROM hive_datasource.table_name
LIMIT 10;

Run HiveQL queries directly on the connected Apache Hive database:

SELECT * FROM hive_datasource (

    --Native Query Goes Here
    FROM (FROM (FROM src
                SELECT TRANSFORM(value)
                USING 'mapper'
                AS value, count) mapped
          SELECT cast(value as double) AS value, cast(count as int) AS count
          SORT BY value, count) sorted
    SELECT TRANSFORM(value, count)
    USING 'reducer'
    AS whatever

);

​

Troubleshooting