org.jzy3d.io.hive.jdbc

Class HiveJdbcClient

java.lang.Object

org.jzy3d.io.hive.jdbc.HiveJdbcClient

public class HiveJdbcClient
extends Object

export HIVE_CONF_DIR=/Users/martin/Dev/hadoop/spark/spark-trials

Author:

martin

Constructor Summary

Constructors

Constructor and Description
HiveJdbcClient()

Method Summary

Modifier and Type	Method and Description
Connection	connect(Config.HiveConnection connection)
Connection	connect(String ip, String port, String domain, String user, String password)
void	count(Statement stmt, String tableName)
void	createTable(Statement stmt, String tableName, String schema)
void	describe(Statement stmt, String tableName)
void	dropTable(Statement stmt, String tableName)
void	exec(Statement stmt, String command)
void	exec(Statement stmt, String command, boolean print)
void	insertInto(Statement stmt, String tableName, int key, String value)
void	loadData(Statement stmt, String tableName, String localInpath)
static void	main(String[] args) https://cwiki.apache.org/confluence/display/Hive/HiveServer2+Clients http: //chase-seibert.github.io/blog/2013/05/17/hive-insert-and-dump-csv-with -map-datatype.html
ResultSet	selectAll(Statement stmt, String tableName)
ResultSet	selectAll(Statement stmt, String tableName, boolean print)
void	showTables(Statement stmt)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveJdbcClient

public HiveJdbcClient()

Method Detail

main

public static void main(String[] args)
                 throws SQLException

https://cwiki.apache.org/confluence/display/Hive/HiveServer2+Clients http: //chase-seibert.github.io/blog/2013/05/17/hive-insert-and-dump-csv-with -map-datatype.html

Throws:

SQLException

connect

public Connection connect(Config.HiveConnection connection)
                   throws SQLException

Throws:

SQLException

connect

public Connection connect(String ip,
                          String port,
                          String domain,
                          String user,
                          String password)
                   throws SQLException

Throws:

SQLException

insertInto

public void insertInto(Statement stmt,
                       String tableName,
                       int key,
                       String value)
                throws SQLException

Throws:

SQLException

count

public void count(Statement stmt,
                  String tableName)
           throws SQLException

Throws:

SQLException

selectAll

public ResultSet selectAll(Statement stmt,
                           String tableName)
                    throws SQLException

Throws:

SQLException

selectAll

public ResultSet selectAll(Statement stmt,
                           String tableName,
                           boolean print)
                    throws SQLException

Throws:

SQLException

loadData

public void loadData(Statement stmt,
                     String tableName,
                     String localInpath)
              throws SQLException

Throws:

SQLException

describe

public void describe(Statement stmt,
                     String tableName)
              throws SQLException

Throws:

SQLException

showTables

public void showTables(Statement stmt)
                throws SQLException

Throws:

SQLException

dropTable

public void dropTable(Statement stmt,
                      String tableName)
               throws SQLException

Throws:

SQLException

createTable

public void createTable(Statement stmt,
                        String tableName,
                        String schema)
                 throws SQLException

Throws:

SQLException

exec

public void exec(Statement stmt,
                 String command)
          throws SQLException

Throws:

SQLException

exec

public void exec(Statement stmt,
                 String command,
                 boolean print)
          throws SQLException

Throws:

SQLException