0

JavaクライアントAPIからhbaseで接続を取得しようとしています。

これは私のコードです。ここでは、hbaseで接続を取得するためのコードをいくつか記述しました。

このコードを実行してもエラーは発生しません。しかし、これでテーブルを作成することはできません。

Configuration hbaseConfiguration = HBaseConfiguration.create();
    try {

        hbaseConfiguration.set("hbase.rootdir",
                "file:///home/sample/hbase");
        hbaseConfiguration.set("hbase.zookeeper.property.dataDir",
                "/home/sample/zookeeper");
        hbaseConfiguration.set("hbase.zookeeper.quorum",
                "sample");
        Configuration newConfig = new Configuration(hbaseConfiguration);
        HConnection connection = HConnectionManager
                .getConnection(newConfig);
        hBaseAdmin = new HBaseAdmin(connection);
        hBaseAdmin.createTable(new HTableDescriptor("sample"));
        if (!hBaseAdmin.isMasterRunning())
            throw new Exception("Hbase is not running");
        tableFactory = new HTableFactory();
    } catch (Exception e) {
        throw new Exception("Hbase is not running");
    }

誰かがこれを手伝ってくれる？ありがとう....

4

2 に答える 2

0

次のコードを変更

    hbaseConfiguration.set("hbase.rootdir",
            "file:///home/sample/hbase");
    hbaseConfiguration.set("hbase.zookeeper.property.dataDir",
            "/home/sample/zookeeper");
    hbaseConfiguration.set("hbase.zookeeper.quorum",
            "sample");

に

hbaseConfiguration.set("hbase.zookeeper.quorum",
            "rs1.example.com");

注: rs1.example.comZookeeper クラスターへのアドレス ポイントに置き換える必要があります。で値を見つけることができますconf/hbase-site.xml。

于 2013-02-26T09:07:58.893 に答える
0

設定はhbase.rootdir完全に無視されます。hbase-site.xmlファイルでのみ設定できます。

于 2015-02-20T20:52:55.637 に答える