Hive - Create Table

Advertisements

Previous Page
Next Page  

En este capítulo se explica cómo crear una tabla y cómo insertar datos en ella. Las convenciones de crear una tabla en Hive es muy similar a la creación de una tabla SQL

Instrucción Create Table

Crear una tabla es una declaración utiliza para crear una tabla en Hive. La sintaxis y el ejemplo son los siguientes:

Sintaxis

CREATE [TEMPORARY] [EXTERNAL] TABLE [IF NOT EXISTS] [db_name.] table_name

[(col_name data_type [COMMENT col_comment], ...)]
[COMMENT table_comment]
[ROW FORMAT row_format]
[STORED AS file_format]

Ejemplo

Supongamos que usted necesita para crear una tabla denominada empleado mediante CREATE TABLE instrucción. La siguiente tabla muestra los campos y sus tipos de datos de tabla de empleado:

Sr No Nombre del campo Tipo de datos
1 Eid Int
2 Nombre Cadena
3 Sueldo Flotación
4 Designación Cadena

Los datos siguientes es un comentario, campos con formato de fila como terminador de campo, Líneas terminador, y tipo de archivo almacenado.

COMMENT ‘Employee details’
FIELDS TERMINATED BY ‘\t’
LINES TERMINATED BY ‘\n’
STORED IN TEXT FILE

La siguiente consulta crea una tabla llamada empleados utilizando los datos anteriores.

hive> CREATE TABLE IF NOT EXISTS employee ( eid int, name String,
> salary String, destination String)
> COMMENT ‘Employee details’
> ROW FORMAT DELIMITED
> FIELDS TERMINATED BY ‘\t’
> LINES TERMINATED BY ‘\n’
> STORED AS TEXTFILE;

Si a ello se agrega la opción SI NO EXISTE, pasa por alto la declaración en caso de que la tabla ya existe.

De creación de la tabla, usted podrá ver la siguiente respuesta:

OK
Time taken: 5.905 seconds
hive>

Programa JDBC

El programa JDBC para crear una tabla se han dado un ejemplo.

import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;

public class HiveCreateTable {
   private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
   
   public static void main(String[] args) throws SQLException {
   
      // Register driver and create driver instance
      Class.forName(driverName);
      
      // get connection
      Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");
      
      // create statement
      Statement stmt = con.createStatement();
      
      // execute statement
      stmt.executeQuery("CREATE TABLE IF NOT EXISTS "
         +" employee ( eid int, name String, "
         +" salary String, destignation String)"
         +" COMMENT ‘Employee details’"
         +" ROW FORMAT DELIMITED"
         +" FIELDS TERMINATED BY ‘\t’"
         +" LINES TERMINATED BY ‘\n’"
         +" STORED AS TEXTFILE;");
         
      System.out.println(“ Table employee created.”);
      con.close();
   }
}

El programa se guarda en un archivo llamado HiveCreateDb.java. Los siguientes comandos se utilizan para compilar y ejecutar este programa.

$ javac HiveCreateDb.java
$ java HiveCreateDb

Salida

Table employee created.

Sentencia Load Data

En general, después de crear una tabla en SQL, podemos introducir los datos utilizando la instrucción Insert. Pero en Hive, podemos introducir datos mediante la sentencia LOAD DATA.

Al insertar datos en Hive, es mejor utilizar para almacenar datos de carga a granel. Hay dos formas de cargar datos: uno es de sistema de archivos local y la segunda es de Hadoop sistema de archivos.

Sintaxis

La sintaxis para carga de datos es el siguiente:

LOAD DATA [LOCAL] INPATH 'filepath' [OVERWRITE] INTO TABLE tablename 
[PARTITION (partcol1=val1, partcol2=val2 ...)]
  • Es el identificador LOCAL para especificar la ruta de acceso local. Es opcional.
  • SOBRESCRIBIR es opcional para sobrescribir los datos de la tabla.
  • PARTICIÓN es opcional.

Ejemplo

Vamos a incluir los siguientes datos en la tabla. Se trata de un archivo de texto llamadosample.txten el directorio /home/directorio de usuario.

1201  Gopal       45000    Technical manager
1202  Manisha     45000    Proof reader
1203  Masthanvali 40000    Technical writer
1204  Kiran       40000    Hr Admin
1205  Kranthi     30000    Op Admin

La consulta siguiente carga el texto dado en la tabla.

hive> LOAD DATA LOCAL INPATH '/home/user/sample.txt'
> OVERWRITE INTO TABLE employee;

En descarga exitosa, usted podrá ver la siguiente respuesta:

OK
Time taken: 15.905 seconds
hive>

Programa JDBC

A continuación se muestra el programa JDBC para cargar datos en la tabla.

import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;

public class HiveLoadData {

   private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
   
   public static void main(String[] args) throws SQLException {
   
      // Register driver and create driver instance
      Class.forName(driverName);
      
      // get connection
      Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");
      
      // create statement
      Statement stmt = con.createStatement();
      
      // execute statement
      stmt.executeQuery("LOAD DATA LOCAL INPATH '/home/user/sample.txt'" + "OVERWRITE INTO TABLE employee;");
      System.out.println("Load Data into employee successful");
      
      con.close();
   }
}

El programa se guarda en un archivo llamado HiveLoadData.java. Utilice los siguientes comandos para compilar y ejecutar este programa.

$ javac HiveLoadData.java
$ java HiveLoadData

Salida:

Load Data into employee successful
Advertisements