Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here. Want to know more about what has changed? Check out the Community News blog.

Regarding Hbase connection using KiteAPI

Regarding Hbase connection using KiteAPI

Explorer

Hi All,

 

I am trying to connect to Hbase using KiteAPI as shown below.

 

DatasetRepository repo = DatasetRepositories.open("repo:hbase:zk1,zk2,zk3");//getting error at this line....
DatasetDescriptor descriptor = new DatasetDescriptor.Builder().schemaUri("weblog.avsc").build();
repo.create("weblogs",descriptor);

 

zk1: replaced with zookeeperserver1ipaddress:2181

zk2:replaced with zookeeperserver2ipaddress:2181

zk3:replaced with zookeeperserver3ipaddress:2181

 

but getting the unknown storage URI error....

 

Anyone worked with Hbase using Kite API.  Please advice me..........