1

Cassandra が使用しているパーティショナーを取得するために、Hector クライアントの次のコードを使用しています。

    CqlQuery<String, String, String> cqlQuery = new CqlQuery<String, String, String>(
            ksp, StringSerializer.get(), StringSerializer.get(), StringSerializer.get());
    cqlQuery.setQuery("select partitioner from local");
    QueryResult<CqlRows<String, String, String>> result = cqlQuery.execute();
    CqlRows rows = result.get();
    for (int i = 0; i < rows.getCount(); i++) {
        RowImpl<String, String, String> row = (RowImpl<String, String, String>) rows.getList().get(i);
        HColumn<String, String> column = row.getColumnSlice().getColumnByName("partitioner");
        String partitioner = column.getName();
    }

しかし失敗し、NullPointerException が返されます。私はcqlshでクエリを試してみましたが、うまくいきましたが、このコードを使用していません。誰が何が悪いのか知っていますか?

ありがとう!

4

0 に答える 0