Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

hbase support

Browse Source
This commit is contained in:
温少
2012-05-19 23:38:43 +08:00
parent 4580108a02
commit 8593a7541b
2 changed files with 22 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/hbase/HEngine.java
+12 -5
View File
@@ -8,11 +8,13 @@ import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.HTableInterface;
import org.apache.hadoop.hbase.client.HTablePool;
import com.alibaba.druid.hbase.mapping.HMapping;
import com.alibaba.druid.logging.Log;
import com.alibaba.druid.logging.LogFactory;
public class HEngine {
private final static Log LOG = LogFactory.getLog(HEngine.class);
private final static Log LOG = LogFactory.getLog(HEngine.class);
private static ConcurrentMap<String, HEngine> engines = new ConcurrentHashMap<String, HEngine>();
@@ -28,11 +30,12 @@ public class HEngine {
// =============================
private final String url;
private final String url;
private HTablePool tablePool;
private int htablePoolMaxSize = 256;
private Configuration config;
private HTablePool tablePool;
private int htablePoolMaxSize = 256;
private Configuration config;
private ConcurrentMap<String, HMapping> mappings = new ConcurrentHashMap<String, HMapping>();
public HEngine(String url, Properties connectProperties){
super();
@@ -64,6 +67,10 @@ public class HEngine {
return config;
}
public ConcurrentMap<String, HMapping> getMappings() {
return mappings;
}
public synchronized HTableInterface getHTable(String tableName) {
if (tablePool == null) {
tablePool = new HTablePool(config, htablePoolMaxSize);
src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java
+10
View File
@@ -7,9 +7,19 @@ import java.util.Map;
public class HMapping {
private String tableName;
private Map<String, HMappingColumn> columns = new LinkedHashMap<String, HMappingColumn>();
private HMappingColumn keyColumn;
public String getTableName() {
return tableName;
}
public void setTableName(String tableName) {
this.tableName = tableName;
}
public Collection<HMappingColumn> getColumns() {
return Collections.unmodifiableCollection(columns.values());
}