HBaseSchemaManager
protected boolean initiateClient()
{
String message = null;
for (String host : hosts)
{
vaildateHostPort(host, port);
Configuration hadoopConf = new Configuration();
hadoopConf.set("hbase.master", host + ":" + port);
conn = HBasePropertyReader.hsmd.getDataStore() != null ? HBasePropertyReader.hsmd.getDataStore()
.getConnection() : null;
if (conn != null && conn.getProperties() != null)
{
String zookeeperHost = conn.getProperties().getProperty("hbase.zookeeper.quorum").trim();
String zookeeperPort = conn.getProperties().getProperty("hbase.zookeeper.property.clientPort").trim();
vaildateHostPort(zookeeperHost, zookeeperPort);
hadoopConf.set("hbase.zookeeper.quorum", zookeeperHost != null ? zookeeperHost : host);
hadoopConf.set("hbase.zookeeper.property.clientPort", zookeeperPort != null ? zookeeperPort
: DEFAULT_ZOOKEEPER_PORT);
}
else
{
hadoopConf.set("hbase.zookeeper.quorum", host);
hadoopConf.set("hbase.zookeeper.property.clientPort", DEFAULT_ZOOKEEPER_PORT);
}
Configuration conf = HBaseConfiguration.create(hadoopConf);
try
{
admin = new HBaseAdmin(conf);
return true;
}
--
You received this message because you are subscribed to the Google Groups "kundera-discuss" group.
To unsubscribe from this group and stop receiving emails from it, send an email to kundera-discu...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.