hbaseとSparkとの接続方法

Question

hbaseからデータをロードし、Spark！ 私はgoogleクラウドとhbaseでスパーク2.0.2を使用しています。1.2.5

インターネット上では、JavaHBaseContextを使用する例がいくつか見つかりましたが、私はこのクラスを見つける場所がわかりません。 hbase-sparkというファイルhbase？

そして私はHBaseのデータベースとの接続を行うためにHBaseConfigurationとのConnectionFactoryを使用している、あまりにもこのコードを発見した：

Configuration conf = HBaseConfiguration.create(); 
    conf.addResource(new Path("/etc/hbase/conf/core-site.xml")); 
    conf.addResource(new Path("/etc/hbase/conf/hbase-site.xml")); 
    conf.set(TableInputFormat.INPUT_TABLE, tableName); 

    Connection connection = ConnectionFactory.createConnection(conf); 

    Admin admin = connection.getAdmin(); 
    Table tab = connection.getTable(TableName.valueOf(tableName)); 
    byte [] row = Bytes.toBytes("TestSpark"); 
    byte [] family1 = Bytes.toBytes("MetaData"); 
    byte [] height = Bytes.toBytes("height"); 
    byte [] width = Bytes.toBytes("width"); 

    Put put = new Put(row); 
    put.addColumn(family1, height, Bytes.toBytes("256")); 
    put.addColumn(family1, width, Bytes.toBytes("384")); 

    tab.put(put); 

しかし、私はあるConnection connection = ConnectionFactory.createConnection(conf);に関するエラーを取得：

error: unreported exception IOException; must be caught or declared to be thrown Connection connection = ConnectionFactory.createConnection(conf);

できますSpabaseを使用してhbaseからデータをロードする方法を教えてください。

PS：私は、Java

Answer 1

あなたはConnection connection = ConnectionFactory.createConnection(conf);がエラーをThowさんことができるという事実に関係しているmentionnedてきたエラーをプログラムします。 A（_ HBaseの-spark.jar`はスパークのための（新たな）標準HBaseのプラグインです `、それはClouderaの貢献によるもの

try {  
    Connection connection = ConnectionFactory.createConnection(conf); 
} 
catch (Exception e) //Replace Exception with the exception thown by ConnectionFactory 
{ 
... Do something. 
}