【发布时间】:2012-07-20 12:39:08
【问题描述】:
嘿,我是 hadoop 和 hive 的新手。我的应用程序现在无法处理多个连接。当连接数增加(超过 4 个)时,它会变慢。哪位大神能看出来。代码如下。
public static void setupDriver(String connectURI) throws Exception {
ObjectPool connectionPool = new GenericObjectPool(null);
ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(
connectURI, username, password);
@SuppressWarnings("unused")
PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(
connectionFactory, connectionPool, null, null, false, true);
Class.forName(poolingDriver);
PoolingDriver driver = (PoolingDriver) DriverManager.getDriver(poolConnection);
driver.registerPool(poolName, connectionPool);
}
stmt = connection.createStatement();
String queryString = "select feed_date,count(feed_date) from twitter_stats where tweet like '%" + searchRequest.getWord() + "%' ";
if (null != searchRequest.getFromDate()) {
queryString += "and feed_date >= '" + searchRequest.getFromDate() + "' ";
}
【问题讨论】:
-
你确定麻烦来自那里吗?我不是 Hive 专家,但从我的数据库经验来看,这很可能是查询概念问题,而不是 java 问题。您能发表您的要求吗?
-
stmt = connection.createStatement(); String queryString = "select feed_date,count(feed_date) from twitter_stats where tweet like '%" + searchRequest.getWord() + "%' "; if (null != searchRequest.getFromDate()) { queryString += "and feed_date >= '" + searchRequest.getFromDate() + "' "; }