com.ailbb.act.hive

Class $Hive

java.lang.Object

com.ailbb.act.hadoop.$Hadoop

com.ailbb.act.hive.$Hive

public class $Hive
extends $Hadoop

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,Object> partition)
com.ailbb.ajj.entity.$Result	createPartition(String table, String path, LinkedHashMap<String,Object> partition)
com.ailbb.ajj.entity.$Result	createTable(String sql)
com.ailbb.ajj.entity.$Result	dropPartition(String table, LinkedHashMap<String,Object> partition)
com.ailbb.ajj.entity.$Result	dropTable(String table)
com.ailbb.ajj.entity.$Result	execute(String sql)
com.ailbb.ajj.entity.$Result	getCols(String db, String table)
com.ailbb.ajj.entity.$JDBCConnConfiguration	getConnConfiguration()
com.ailbb.ajj.entity.$Result	getDBS()
org.springframework.jdbc.core.JdbcTemplate	getJdbcTemplate()
com.ailbb.ajj.entity.$Result	getTables(String db)
$Hive	init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)
$Hive	init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration, $Kerberos kerberos)
com.ailbb.ajj.entity.$Result	loadTable(String table, String path)
com.ailbb.ajj.entity.$Result	loadTable(String table, String path, boolean isDelete)
com.ailbb.ajj.entity.$Result	loadTable(String table, String path, Map<String,Object> partition)
com.ailbb.ajj.entity.$Result	loadTable(String table, String path, Map<String,Object> partition, boolean isDelete)
static void	main(String[] args)
com.ailbb.ajj.entity.$Result	query(String sql)
List<Map<String,Object>>	queryForList(String sql)
com.ailbb.ajj.entity.$Result	run(String sql)
com.ailbb.ajj.entity.$Result	run(String sql, List<Object> list)
$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

Throws:

Exception

main

public static void main(String[] args)

init

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

Throws:

Exception

getDBS

public com.ailbb.ajj.entity.$Result getDBS()

getTables

public com.ailbb.ajj.entity.$Result getTables(String db)

getCols

public com.ailbb.ajj.entity.$Result getCols(String db,
                                            String table)

createTable

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

dropTable

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

loadTable

public com.ailbb.ajj.entity.$Result loadTable(String table,
                                              String path)

loadTable

public com.ailbb.ajj.entity.$Result loadTable(String table,
                                              String path,
                                              boolean isDelete)

loadTable

public com.ailbb.ajj.entity.$Result loadTable(String table,
                                              String path,
                                              Map<String,Object> partition)

loadTable

public com.ailbb.ajj.entity.$Result loadTable(String table,
                                              String path,
                                              Map<String,Object> partition,
                                              boolean isDelete)

createPartition

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

createPartition

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

dropPartition

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

run

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

query

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

queryForList

public List<Map<String,Object>> queryForList(String sql)

execute

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

run

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

getJdbcTemplate

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

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)