public class $Hive extends $Hadoop
| Constructor and Description |
|---|
$Hive() |
| 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) |
getKerberos, run, setKerberospublic static final String $DRIVER
public static final int $PORT
public $Hive init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration) throws Exception
Exceptionpublic static void main(String[] args)
public $Hive init(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration, $Kerberos kerberos) throws Exception
Exceptionpublic com.ailbb.ajj.entity.$Result getDBS()
public com.ailbb.ajj.entity.$Result getTables(String db)
public com.ailbb.ajj.entity.$Result createTable(String sql)
public com.ailbb.ajj.entity.$Result dropTable(String table)
public com.ailbb.ajj.entity.$Result loadTable(String table, String path, boolean isDelete)
public com.ailbb.ajj.entity.$Result loadTable(String table, String path, Map<String,Object> partition)
public com.ailbb.ajj.entity.$Result loadTable(String table, String path, Map<String,Object> partition, boolean isDelete)
public com.ailbb.ajj.entity.$Result createPartition(String table, String path, LinkedHashMap<String,Object> partition)
public com.ailbb.ajj.entity.$Result createPartition(String table, LinkedHashMap<String,Object> partition)
public com.ailbb.ajj.entity.$Result dropPartition(String table, LinkedHashMap<String,Object> partition)
public com.ailbb.ajj.entity.$Result query(String sql)
public com.ailbb.ajj.entity.$Result execute(String sql)
public com.ailbb.ajj.entity.$Result run(String sql)
public org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate()
public $Hive setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)
public com.ailbb.ajj.entity.$JDBCConnConfiguration getConnConfiguration()
public $Hive setConnConfiguration(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)
public com.ailbb.ajj.entity.$JDBCConnConfiguration setDataSourceUrl(com.ailbb.ajj.entity.$JDBCConnConfiguration connConfiguration)
Copyright © 2021. All rights reserved.