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でクエリを試してみましたが、うまくいきましたが、このコードを使用していません。誰が何が悪いのか知っていますか?
ありがとう!