com.ailbb.act.hive

Class $Hive

java.lang.Object

com.ailbb.act.hadoop.$Hadoop

com.ailbb.act.hive.$Hive

public class $Hive
extends $Hadoop

Created by Wz on 8/10/2018.

Field Summary

Fields

Modifier and Type	Field and Description
static String	$DRIVER
static int	$PORT

Constructor Summary

Constructors

Constructor and Description
$Hive()

Method Summary

Modifier and Type	Method and Description
com.ailbb.ajj.entity.$Result	createPartition(String table, LinkedHashMap<String,String> partition) 建分区
com.ailbb.ajj.entity.$Result	createPartition(String table, String path, LinkedHashMap<String,String> partition) 建分区
com.ailbb.ajj.entity.$Result	createTable(String sql) 建表
com.ailbb.ajj.entity.$Result	dropPartition(String table, LinkedHashMap<String,String> partition) 删分区
com.ailbb.ajj.entity.$Result	dropTable(String table) 删表
com.ailbb.ajj.entity.$JDBCConnConfiguration	getConnConfiguration()
org.springframework.jdbc.core.JdbcTemplate	getJdbcTemplate() get/set方法
$Hive	init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration) 初始化方法
$Hive	init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration, $Kerberos kerberos) 初始化方法
com.ailbb.ajj.entity.$Result	run(String sql) 执行sql
com.ailbb.ajj.entity.$Result	run(String sql, List<Object> list) 执行sql
$Hive	setConnConfiguration(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)
com.ailbb.ajj.entity.$JDBCConnConfiguration	setDataSourceUrl(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration) 获取连接串
$Hive	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)

Methods inherited from class com.ailbb.act.hadoop.$Hadoop

getKerberos, run, setKerberos

Methods inherited from class java.lang.Object

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

Field Detail

$DRIVER

public static final String $DRIVER

See Also:

Constant Field Values

$PORT

public static final int $PORT

See Also:

Constant Field Values

Constructor Detail

$Hive

public $Hive()

Method Detail

init

public $Hive init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)
           throws Exception

初始化方法

Parameters:

connConfiguration -

Returns:

Throws:

Exception

init

public $Hive init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration,
                  $Kerberos kerberos)
           throws Exception

初始化方法

Parameters:

connConfiguration -

Returns:

Throws:

Exception

createTable

public com.ailbb.ajj.entity.$Result createTable(String sql)

建表

Returns:

dropTable

public com.ailbb.ajj.entity.$Result dropTable(String table)

删表

Returns:

createPartition

public com.ailbb.ajj.entity.$Result createPartition(String table,
                                                    String path,
                                                    LinkedHashMap<String,String> partition)

建分区

Returns:

createPartition

public com.ailbb.ajj.entity.$Result createPartition(String table,
                                                    LinkedHashMap<String,String> partition)

建分区

Returns:

dropPartition

public com.ailbb.ajj.entity.$Result dropPartition(String table,
                                                  LinkedHashMap<String,String> partition)

删分区

Returns:

run

public com.ailbb.ajj.entity.$Result run(String sql,
                                        List<Object> list)

执行sql

Parameters:

sql - 执行sql

list - 参数

Returns:

$Result 结构体

run

public com.ailbb.ajj.entity.$Result run(String sql)

执行sql

Parameters:

sql - 执行sql

Returns:

$Result 结构体

getJdbcTemplate

public org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate()

get/set方法

Returns:

jdbc连接

setJdbcTemplate

public $Hive setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)

getConnConfiguration

public com.ailbb.ajj.entity.$JDBCConnConfiguration getConnConfiguration()

setConnConfiguration

public $Hive setConnConfiguration(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)

setDataSourceUrl

public com.ailbb.ajj.entity.$JDBCConnConfiguration setDataSourceUrl(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)

获取连接串

Returns:

jdbc连接配置