3

列ファミリーからすべての行を取得し、すべての列も表示したいと思います。私はこれを試しました：

// Static import of HFactory!

// First, insert the data
Mutator<String> mutator = HFactory.createMutator(fKeyspace, fStringS);
mutator.insert("fahrer1", "Fahrer", createStringColumn("first", "John"));
mutator.insert("fahrer2", "Fahrer", createStringColumn("first", "Vorname"));
mutator.insert("fahrer2", "Fahrer", createStringColumn("second", "Nachname"));
mutator.
    addInsertion("fahrer3", "Fahrer",
            createColumn("first", "Firstname", fStringS,
                    fStringS)).
    addInsertion("fahrer3", "Fahrer",
            createColumn("second", "Lastname", fStringS,
                    fStringS)).
    addInsertion("fahrer3", "Fahrer",
            createColumn("age", 29L, fStringS, fLongS))
    .execute();

// Now select..
CqlQuery<String, String, String> cqlQuery =
   new CqlQuery<String, String, String>(fKeyspace,fStringS,fStringS,fStringS);
cqlQuery.setQuery("SELECT * FROM ColumnFamily");

QueryResult<CqlRows<String, String, String>> result = cqlQuery.execute();

CqlRows<String, String, String> rows = result.get();
for (Row<String, String, String> row : rows.getList()) {
    System.out.println(row.getKey() + ":");
    for(HColumn<String, Object>col : row.getColumnSlice().getColumns()) {
        System.out.println(col.getName() + " : " + col.getValue());
        }
    }
}

問題は、たとえばlong値を持つすべての列が空であるということです。最後の「パラメータ化機能」をオブジェクトに変更すると、「CorruptedStreamException」が発生します。どうすればこれを行う必要がありますか？

更新：これはCLIを使用した出力です

[default@Autorennen] list Fahrer;
Using default limit of 100
-------------------
RowKey: fahrer1
=> (column=first, value=John, timestamp=1308392358211000)
-------------------
RowKey: fahrer2
=> (column=first, value=SecondUpdated, timestamp=1308392358350000)
=> (column=second, value=584e6163686e616d65, timestamp=1308392358284000)
-------------------
RowKey: fahrer3
=> (column=age, value=000000000000001d, timestamp=1308392358286002)
=> (column=first, value=Firstname, timestamp=1308392358286000)
=> (column=second, value=4c6173746e616d65, timestamp=1308392358286001)
4

2 に答える 2

4

MLからの回答：http： //groups.google.com/group/hector-users/browse_thread/thread/8246ad59c9d5cf9d

また、新しいテンプレートパッケージもご覧ください。これにより、入力された結果をより適切に取得できます。これを利用したスタートガイドは次のとおりです： https ：//github.com/rantav/hector/wiki/Getting-started-%285-minutes%29

于 2011-06-20T23:01:30.300 に答える
1

Objectの代わりにbyte[]を使用してみましたか？すべてのCassandraデータ項目の基になるタイプはバイト配列です。例えば

QueryResult<CqlRows<String, String, byte[]>>

これは、JavaではなくPythonクライアントを使用しているため、Webの例からの推測に基づいています...

ジェネリックを省略してみることもできます。

CqlResult result = executeQuery("select * from ColumnFamily");
for (CqlRow row : result.getRows()) {
    System.out.println(new String (row.getKey()));
}

そして、もしあれば、あなたがどのタイプを取り戻すかを見てください。

于 2011-06-20T16:15:27.630 に答える